StreamingControlHandle

risingwave_rpc_client

Type Alias StreamingControlHandle 

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

Aliased Type§

pub 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>>