Searched refs:StreamingCallSink (Results 1 – 2 of 2) sorted by relevance
316 pub struct StreamingCallSink<Req> { struct323 impl<Req> StreamingCallSink<Req> { impl324 fn new(call: Arc<Mutex<ShareCall>>, req_ser: SerializeFn<Req>) -> StreamingCallSink<Req> { in new()325 StreamingCallSink { in new()352 impl<P> Drop for StreamingCallSink<P> { implementation364 impl<Req> Sink<(Req, WriteFlags)> for StreamingCallSink<Req> { implementation416 pub type ClientCStreamSender<T> = StreamingCallSink<T>;422 pub type ClientDuplexSender<T> = StreamingCallSink<T>;
49 ClientDuplexSender, ClientSStreamReceiver, ClientUnaryReceiver, StreamingCallSink,