Struct NatsTransport 

pub struct NatsTransport { /* private fields */ }

Owns a NATS connection and transport configuration.

Implementations

impl NatsTransport

pub fn new(client: Client, config: NatsTransportConfig) -> Self

pub fn client(&self) -> &Client

pub async fn serve<H, Fut>( &self, subject: &str, protocol_label: &'static str, handler: H, ) -> Result<(), NatsProtocolError>

where H: Fn(NatsTransport, Message) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), NatsProtocolError>> + Send + 'static,

Subscribe to a NATS subject and dispatch each message to a handler.

pub async fn publish_run_stream<E, BuildEncoder>( &self, run: RunStream, reply: Subject, build_encoder: BuildEncoder, ) -> Result<(), NatsProtocolError>

where E: Transcoder<Input = AgentEvent> + 'static, E::Output: Serialize + Send + 'static, BuildEncoder: FnOnce(&RunStream) -> E,

Trait Implementations

impl Clone for NatsTransport

fn clone(&self) -> NatsTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.