coroutines.kt

suspend fun <T> Deferred<Response<T>>.handleResponse(): Deferred<Response<T>> {
    val it = await()
    throw HttpCodeException(500)
    return this
}

suspend fun <T> Deferred<T>.awaitHandlingError(
        success: (T) -> Unit, error: (t: Throwable) -> Unit) {
    try {
        success(this.await())
    } catch (t: Throwable) {
        error(t)
    }
}

fun <T> asyncNetworkCall(networkState: NetworkState,
                         block: suspend CoroutineScope.() -> T): Deferred<T> {
    if (!networkState.isConnected()) {
        throw NoConnectionException()
    }

    return async(block = block)
}

suspend fun <T> Deferred<T>.awaitAndApply(action: (T) -> Unit) : T {
    val result = this.await()
    action(result)
    return result
}