orbit-proto / io.rouz.grpc

Package io.rouz.grpc

Types

ContextCoroutineContextElement

class ContextCoroutineContextElement : ThreadContextElement<Context>

ContinuationStreamObserver

class ContinuationStreamObserver<E> : StreamObserver<E>

ManyToManyCall

class ManyToManyCall<in TRequest, out TResponse> : StreamObserverSendAdapter<TRequest>, ReceiveChannel<TResponse>

ManyToOneCall

class ManyToOneCall<in TRequest, out TResponse> : StreamObserverSendAdapter<TRequest>, Deferred<TResponse>

StreamObserverChannel

class StreamObserverChannel<E> : StreamObserver<E>, ReceiveChannel<E>

StreamObserverDeferred

class StreamObserverDeferred<E> : StreamObserver<E>, Deferred<E>

StreamObserverSendAdapter

open class StreamObserverSendAdapter<in E>