CoroutineScope Network Example

import android.util.Log
import kotlinx.coroutines.*

/**
 * async task -> coroutine scope
 *
 * @param Result
 * @constructor Create empty Coroutine task async
 */
abstract class CoroutineTaskAsync<Result> {

    private var coroutineScope: CoroutineScope? = null

    open fun execute() {
        coroutineScope?.cancel()
        coroutineScope = MainScope()
        coroutineScope?.launch(errorHandler) {
            onReady()
            try {
                val defer = async(Dispatchers.IO) {
                    Log.i("task", "Async Fetch Started")
                    onRunning()
                }
                val result = defer.await()
                onResult(result)
            } catch (e: CancellationException) {
                Log.i("task", "Async Cancel Result")
            }
        }
    }

    abstract suspend fun onReady()

    abstract suspend fun onRunning(): Result

    abstract suspend fun onResult(result: Result)

    open fun onCancel() {
        if (coroutineScope?.isActive == true) {
            coroutineScope?.cancel()
        }
    }

    private val errorHandler = CoroutineExceptionHandler { context, error ->
        coroutineScope?.launch(Dispatchers.Main) {
            Log.i("task", "Async Exception Result")
        }
    }
}

 

AsyncTask 처럼 비슷하게 쓸 수 있음

 

 

 

 

 

참조 : https://github.com/elye/demo_android_coroutine_network_fetch