class ContinuationStreamObserver<E> : StreamObserver<E>
<init> |
ContinuationStreamObserver(continuation: Continuation<E>) |
onCompleted |
fun onCompleted(): Unit |
onError |
fun onError(t: Throwable): Unit |
onNext |
fun onNext(value: E): Unit |