Struct StreamContext 

#[non_exhaustive]
pub struct StreamContext<Context: ServiceContext> {
    pub service: Arc<ServiceState<Context>>,
    /* private fields */
}

Stream context.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

service: Arc<ServiceState<Context>>

Service shared state.

Implementations

impl<Context: ServiceContext> StreamContext<Context>

pub fn context(&self) -> &Context

Shared context.

pub fn nats(&self) -> Client

NATS connection.

pub fn jetstream(&self) -> &Context

NATS JetStream connection.

pub async fn send<Subject: ToSubject>( &self, subject: Subject, message: &impl Serialize, ) -> Result<PublishAckFuture, PublishError>

Publish a message to the stream.

pub async fn send_with_headers<Subject: ToSubject>( &self, subject: Subject, headers: HeaderMap, message: &impl Serialize, ) -> Result<PublishAckFuture, PublishError>

Publish a message with headers to the stream.