pub trait ProtoStorage: Send + Sync + 'static {
    type CommandResponseStreamStream: Stream<Item = Result<ProtoStorageResponse, Status>> + Send + 'static;

    fn command_response_stream<'life0, 'async_trait>(
        &'life0 self,
        request: Request<Streaming<ProtoStorageCommand>>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::CommandResponseStreamStream>, Status>> + Send + 'async_trait>>
        Self: 'async_trait,
        'life0: 'async_trait
; }
Expand description

Generated trait containing gRPC methods that should be implemented for use with ProtoStorageServer.

Required Associated Types§

Server streaming response type for the CommandResponseStream method.

Required Methods§

Implementations on Foreign Types§