Trait LpService 

pub trait LpService:
    Send
    + Sync
    + 'static {
    type StreamEtfLpStatusStream: Stream<Item = Result<EtfLpStatus, Status>> + Send + 'static;
    type StreamEtfErrorsStream: Stream<Item = Result<EtfLpError, Status>> + Send + 'static;
    type StreamUserOrderbookStream: Stream<Item = Result<UserOrderbookData, Status>> + Send + 'static;

    // Required methods
    fn get_etf_lp<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetEtfLpRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<EtfLp>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_etf_lps<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListEtfLpsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListEtfLpsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_etf_lp<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateEtfLpRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<EtfLp>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_etf_lp_status<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetEtfLpStatusRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<EtfLpStatus>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stream_etf_lp_status<'life0, 'async_trait>(
        &'life0 self,
        request: Request<StreamEtfLpStatusRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamEtfLpStatusStream>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn start_etf_lp<'life0, 'async_trait>(
        &'life0 self,
        request: Request<StartEtfLpRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<StartEtfLpResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stop_etf_lp<'life0, 'async_trait>(
        &'life0 self,
        request: Request<StopEtfLpRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<StopEtfLpResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stream_etf_errors<'life0, 'async_trait>(
        &'life0 self,
        request: Request<StreamEtfErrorsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamEtfErrorsStream>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_user_orderbook<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetUserOrderBookRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<UserOrderbookData>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stream_user_orderbook<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetUserOrderBookRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamUserOrderbookStream>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

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

Required Associated Types

type StreamEtfLpStatusStream: Stream<Item = Result<EtfLpStatus, Status>> + Send + 'static

Server streaming response type for the StreamEtfLpStatus method.

type StreamEtfErrorsStream: Stream<Item = Result<EtfLpError, Status>> + Send + 'static

Server streaming response type for the StreamEtfErrors method.

type StreamUserOrderbookStream: Stream<Item = Result<UserOrderbookData, Status>> + Send + 'static

Server streaming response type for the StreamUserOrderbook method.

Required Methods

fn get_etf_lp<'life0, 'async_trait>( &'life0 self, request: Request<GetEtfLpRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<EtfLp>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_etf_lps<'life0, 'async_trait>( &'life0 self, request: Request<ListEtfLpsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListEtfLpsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn update_etf_lp<'life0, 'async_trait>( &'life0 self, request: Request<UpdateEtfLpRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<EtfLp>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_etf_lp_status<'life0, 'async_trait>( &'life0 self, request: Request<GetEtfLpStatusRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<EtfLpStatus>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stream_etf_lp_status<'life0, 'async_trait>( &'life0 self, request: Request<StreamEtfLpStatusRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamEtfLpStatusStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn start_etf_lp<'life0, 'async_trait>( &'life0 self, request: Request<StartEtfLpRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StartEtfLpResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stop_etf_lp<'life0, 'async_trait>( &'life0 self, request: Request<StopEtfLpRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StopEtfLpResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stream_etf_errors<'life0, 'async_trait>( &'life0 self, request: Request<StreamEtfErrorsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamEtfErrorsStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_user_orderbook<'life0, 'async_trait>( &'life0 self, request: Request<GetUserOrderBookRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UserOrderbookData>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stream_user_orderbook<'life0, 'async_trait>( &'life0 self, request: Request<GetUserOrderBookRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamUserOrderbookStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors