Struct JetStreamRCService

pub struct JetStreamRCService<T: Send + JetStreamAsyncService>(/* private fields */);

Implementations

impl<T: Send + JetStreamAsyncService> JetStreamRCService<T>

pub fn new(inner: T) -> Self

Trait Implementations

impl<T> Clone for JetStreamRCService<T>

where T: Send + JetStreamAsyncService,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Send + JetStreamAsyncService> Debug for JetStreamRCService<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Send + JetStreamAsyncService> JetStreamAsyncService for JetStreamRCService<T>

fn rpc<'life0, 'async_trait>( &'life0 mut self, req: Self::Request, ) -> Pin<Box<dyn Future<Output = Result<Self::Response, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

fn handle_message<'life0, 'life1, 'life2, 'async_trait, R, W>( &'life0 mut self, reader: &'life1 mut R, writer: &'life2 mut W, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where R: AsyncReadExt + Unpin + Send + 'async_trait, W: AsyncWriteExt + Unpin + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

impl<T: JetStreamAsyncService> JetStreamProtocol for JetStreamRCService<T>

type Request = <T as JetStreamProtocol>::Request

type Response = <T as JetStreamProtocol>::Response

impl<T> JetStreamSharedService for JetStreamRCService<T>

where T: Send + JetStreamAsyncService,