Struct WorkQueueSink 

pub struct WorkQueueSink<T, C: CodecType> { /* private fields */ }

A sink for pushing messages to a work queue.

Implementations

impl<T: Serialize, C: CodecType> WorkQueueSink<T, C>

pub async fn publish(&self, message: &T) -> Result<u64>

Publish a message directly with error handling.

Unlike the Sink implementation, this method returns any publish errors and waits for JetStream acknowledgment.

Example

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

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

let client = Client::<MsgPackCodec>::connect("nats://localhost:4222").await?;
let jetstream = client.jetstream();
let queue = WorkQueue::<Job, MsgPackCodec>::builder(&jetstream, "jobs").create().await?;
let sink = queue.sink();

// Direct publish with acknowledgment
let seq = sink.publish(&Job { id: 1 }).await?;
println!("Published at sequence: {}", seq);

Trait Implementations

impl<T, C: CodecType> Clone for WorkQueueSink<T, C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Serialize, C: CodecType> Sink<T> for WorkQueueSink<T, C>

type Error = Error

The type of value produced by the sink when an error occurs.

fn poll_ready(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to prepare the Sink to receive a value.

fn start_send(self: Pin<&mut Self>, item: T) -> Result<()>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Flush any remaining output from this sink.

fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Flush any remaining output and close this sink, if necessary.