risingwave_rpc_client::stream_client

Type Alias StreamingControlHandle

source 
pub type StreamingControlHandle = UnboundedBidiStreamHandle<StreamingControlStreamRequest, StreamingControlStreamResponse>;

Aliased Type§

struct StreamingControlHandle {
    pub request_sender: UnboundedSender<StreamingControlStreamRequest>,
    pub response_stream: Pin<Box<dyn Stream<Item = Result<StreamingControlStreamResponse, RpcError>> + Send>>,
}

Fields§

§request_sender: UnboundedSender<StreamingControlStreamRequest>§response_stream: Pin<Box<dyn Stream<Item = Result<StreamingControlStreamResponse, RpcError>> + Send>>