Struct StreamConnect 

pub struct StreamConnect { /* private fields */ }

Implementations

impl StreamConnect

pub fn new(state: AppState) -> Self

Trait Implementations

impl Clone for StreamConnect

fn clone(&self) -> StreamConnect

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Service for StreamConnect

async fn subscribe( &self, ctx: Context, request: OwnedView<SubscribeRequestView<'static>>, ) -> Result<(Pin<Box<dyn Stream<Item = Result<SubscribeResponse, ConnectError>> + Send>>, Context), ConnectError>

Handle the Subscribe RPC.

async fn get( &self, ctx: Context, request: OwnedView<GetRequestView<'static>>, ) -> Result<(StreamGetResponse, Context), ConnectError>

Handle the Get RPC.