Closed rouzwawi closed 6 years ago
This switches the signature on server streaming handlers to be executed within a ProducerScope<TReply>.
ProducerScope<TReply>
- override suspend fun greetServerStream(request: TRequest) = produce<TReply> { ... } + override suspend fun ProducerScope<TReply>.greetServerStream(request: TRequest) { ... }
It also makes exception propagation more consistent across the various rpc types by always following these rules:
StatusException
StatusRuntimeException
UNKNOWN
INTERNAL
CoroutineScope
This switches the signature on server streaming handlers to be executed within a
ProducerScope<TReply>
.It also makes exception propagation more consistent across the various rpc types by always following these rules:
StatusException
orStatusRuntimeException
UNKNOWN
orINTERNAL
, and propagated to theCoroutineScope
that is used in the service constructor