class StreamObserverDeferred<E> : StreamObserver<E>, Deferred<E>
<init> |
StreamObserverDeferred(deferred: CompletableDeferred<E> = CompletableDeferred()) |
onCompleted |
fun onCompleted(): Unit |
onError |
fun onError(t: Throwable): Unit |
onNext |
fun onNext(value: E): Unit |