class StreamObserverChannel<E> : StreamObserver<E>, ReceiveChannel<E>
<init> |
StreamObserverChannel(channel: Channel<E> = Channel<E>(Channel.UNLIMITED)) |
onCompleted |
fun onCompleted(): Unit |
onError |
fun onError(t: Throwable?): Unit |
onNext |
fun onNext(value: E): Unit |