getCancellationException

>> IMPORTANT NOTE: We advise library authors to follow the same convention: add the “experimental” (e.g. com.example.experimental) suffix to your packages exposing coroutine-based APIs so that your library remains binary compatible. When the final API is released, follow these steps:

Int

object

BroadcastChannel

ReceivingChannel

for

launch {}

java.lang.NullPointerException: Attempt to invoke interface method 'kotlin.coroutines.experimental.CoroutineContext$Element kotlin.coroutines.experimental.CoroutineContext.get(kotlin.coroutines.experimental.CoroutineContext$Key)' on a null object reference

onX

Channel

CancellationException

suspend fun call(): Element {
    return suspendCancellableCoroutine { continuation ->
        client.request(Element("request"), object : Handler {
            override fun success(response: Element) {
                continuation.resume(response)
            }

            override fun error(response: Element) {
                continuation.resume(response)
            }
        })
    }
}

try {
    val element = xmpp.request(Element("request"))
    println("Received element: $element")
} catch (error: FailureException) {
    println("oops... error! ${error.condition}")
} catch (timeout: TimeoutException) {
    println("timeout")
}

class ResourceManager<out T>(private val resource: T, readConcurrency: Int) {

  private val readWriteLock = ReentrantReadWriteLock()
  private val readContext = newFixedThreadPoolContext(readConcurrency, "reader")
  private val writeContext = newSingleThreadContext("writer")

  suspend fun <R> read(block: (T) -> R): R = withContext(readContext) {
    readWriteLock.readLock().withLock { block(resource) }
  }

  suspend fun <R> write(block: (T) -> R): R = withContext(writeContext) {
    readWriteLock.writeLock().withLock { block(resource) }
  }

}

CoroutineContext

TestScheduler

triggerActions

advanceTimeBy

TestCoroutineContext