Coroutine Kotlin Android с дооснащением - PullRequest
Новая
       11

Coroutine Kotlin Android с дооснащением

1 голос
/ 31 марта 2019 
class Service{
    interface  RedditApi {
        @GET("/top.json")
        fun getTop(@Query("after") after: String,
                   @Query("limit") limit: String)
                : Deferred<Response<News>>;
    }
}
 val okHttpClient = OkHttpClient.Builder()
            .readTimeout(40, TimeUnit.SECONDS)
            .addInterceptor { chain ->
                val ongoing = chain.request().newBuilder()
                ongoing.addHeader("Cache-Control", "no-cache")
                ongoing.addHeader("User-Agent", System.getProperty("http.agent"))
                //ongoing.addHeader("Authorization", val.trim());
                chain.proceed(ongoing.build())
            }
            .connectTimeout(40, TimeUnit.SECONDS)
            .build()
        val retrofit = Retrofit.Builder()
            .baseUrl( "/rest/s1/mobile/")
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(CoroutineCallAdapterFactory())
            .client(okHttpClient)
            .build()
        redditApi = retrofit.create(Service.RedditApi::class.java)

Ладно, я пытаюсь использовать модификацию с Coroutine. Я перехожу к своей деятельности и реализую ее, как показано ниже. Я получаю сообщения об ошибках. Основная неразрешенная ссылка main. Я использую kotlin 1.3.21. Кроме того, другой мой вопрос: что, если пользователь щелкнет обратно по действию, как я могу отменить операцию сопрограммы? Как и в Java, я использовал call.cancel () с модификацией. Он отменил вызов. 

class MainActivity : AppCompatActivity(), Fightable {
        override fun onCreate(savedInstanceState: Bundle?) {
            super.onCreate(savedInstanceState)
            setContentView(R.layout.activity_main)


            CoroutineScope(Dispatchers.IO).launch {
                val request = App.redditApi.getTop("after", "limit")
                withContext(Dispatchers.Main) {
                    try {
                        val response = request.await()
                        if (response.isSuccessful) {
                            val news: News? = response.body()
                            //Do something with response e.g show to the UI.
                        } else {
                        }
                    } catch (e: HttpException) {
                    } catch (e: Throwable) {
                    }
                }
            }}}

1 Ответ

1 голос
/ 31 марта 2019

Вам необходимо создать один экземпляр контекста сопрограммы, а также задать для него задание. val job = Job() val coroutineScope = CoroutineContext(Dispatchers.Main+job)

И начните работу, используя объявленную область, и, когда вы хотите отменить работу, вы можете просто позвонить job.cancel(), который отменяет все текущие и предстоящие работы.

...