Struct SharedJetStreamService

pub struct SharedJetStreamService<S: Service> { /* private fields */ }

A shared, thread-safe JetStream service that can be cloned.

Implementations

impl<S: Service> SharedJetStreamService<S>

pub fn new(service: S) -> Self

Creates a new shared JetStream service.

Trait Implementations

impl<S: Clone + Service> Clone for SharedJetStreamService<S>

fn clone(&self) -> SharedJetStreamService<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Service> Protocol for SharedJetStreamService<S>

type Request = <S as Protocol>::Request

type Response = <S as Protocol>::Response

impl<S: Service> Service for SharedJetStreamService<S>

async fn rpc(&mut self, req: Self::Request) -> Result<Self::Response, Error>

Handles an RPC call asynchronously.

fn handle_message<R, W>( &mut self, reader: &mut R, writer: &mut W, ) -> impl Future<Output = Result<(), Error>> + Send + Sync

where R: AsyncReadExt + Unpin + Send + Sync, W: AsyncWriteExt + Unpin + Send + Sync,

Handles a message by reading from the reader, processing it, and writing the response.