Enum async_nats::Command

pub enum Command {
    Publish {
        subject: String,
        payload: Bytes,
        respond: Option<String>,
        headers: Option<HeaderMap>,
    },
    Subscribe {
        sid: u64,
        subject: String,
        queue_group: Option<String>,
        sender: Sender<Message>,
    },
    Unsubscribe {
        sid: u64,
        max: Option<u64>,
    },
    Ping,
    Flush {
        result: Sender<Result<(), Error>>,
    },
    TryFlush,
    Connect(ConnectInfo),
}

Variants

Publish

Fields

subject: String

payload: Bytes

respond: Option<String>

headers: Option<HeaderMap>

Subscribe

Fields

sid: u64

subject: String

queue_group: Option<String>

sender: Sender<Message>

Unsubscribe

Fields

sid: u64

max: Option<u64>

Ping

Flush

Fields

result: Sender<Result<(), Error>>

TryFlush

Connect(ConnectInfo)

Trait Implementations

impl Debug for Command

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.