open class StreamObserverSendAdapter<in E>
<init> |
StreamObserverSendAdapter(streamObserver: StreamObserver<E>) |
close |
fun close(cause: Throwable? = null): Boolean |
send |
fun send(element: E): Unit |
ManyToManyCall |
class ManyToManyCall<in TRequest, out TResponse> : StreamObserverSendAdapter<TRequest>, ReceiveChannel<TResponse> |
ManyToOneCall |
class ManyToOneCall<in TRequest, out TResponse> : StreamObserverSendAdapter<TRequest>, Deferred<TResponse> |