Struct Stream 

pub struct Stream<C: CodecType> { /* private fields */ }

A JetStream stream with configurable codec.

Type Parameters

• C - The codec type used for message serialization

Implementations

impl<C: CodecType> Stream<C>

pub fn inner(&self) -> &Stream

Get the underlying async-nats stream.

pub fn name(&self) -> &str

Get the stream name.

pub async fn info(&self) -> Result<StreamInfo>

Get stream information.

pub fn pull_consumer_builder<T>(&self, name: &str) -> PullConsumerBuilder<T, C>

Create a pull consumer builder.

Type Parameters

• T - The message type for this consumer

Example

use intercom::{Client, MsgPackCodec};
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug)]
struct Event { id: u64 }

let client = Client::<MsgPackCodec>::connect("nats://localhost:4222").await?;
let jetstream = client.jetstream();
let stream = jetstream.get_stream("events").await?;

let consumer = stream
    .pull_consumer_builder::<Event>("my-consumer")
    .durable()
    .filter_subject("events.user.>")
    .create()
    .await?;

pub fn push_consumer_builder<T>(&self, name: &str) -> PushConsumerBuilder<T, C>

Create a push consumer builder.

Type Parameters

• T - The message type for this consumer

Example

use intercom::{Client, MsgPackCodec};
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug)]
struct Event { id: u64 }

let client = Client::<MsgPackCodec>::connect("nats://localhost:4222").await?;
let jetstream = client.jetstream();
let stream = jetstream.get_stream("events").await?;

let consumer = stream
    .push_consumer_builder::<Event>("my-push-consumer")
    .deliver_subject("deliver.events")
    .create()
    .await?;

pub async fn get_pull_consumer<T>( &self, name: &str, ) -> Result<PullConsumer<T, C>>

Get an existing pull consumer by name.

pub async fn get_push_consumer<T>( &self, name: &str, ) -> Result<PushConsumer<T, C>>

Get an existing push consumer by name.

pub async fn delete_consumer(&self, name: &str) -> Result<()>

Delete a consumer by name.

pub async fn purge(&self) -> Result<u64>

Purge all messages from the stream.

pub async fn purge_subject(&self, filter: &str) -> Result<u64>

Purge messages matching a filter subject.

Trait Implementations

impl<C: Clone + CodecType> Clone for Stream<C>

fn clone(&self) -> Stream<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.