Struct pulsar::producer::MultiTopicProducer

pub struct MultiTopicProducer<Exe: Executor> { /* fields omitted */ }

Wrapper structure that manges multiple producers at once, creating them as needed

use pulsar::{Pulsar, TokioExecutor};

let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await?;
let mut producer = pulsar.producer()
    .with_name("name")
    .build_multi_topic();
let send_1 = producer.send(topic, &message).await?;
let send_2 = producer.send(topic, &message).await?;
send_1.await?;
send_2.await?;

Implementations

impl<Exe: Executor> MultiTopicProducer<Exe>

pub fn options(&self) -> &ProducerOptions

pub fn topics(&self) -> Vec<String>

pub async fn close_producer<S: Into<String>, '_>(
    &'_ mut self,
    topic: S
) -> Result<(), Error>

pub async fn send<T: SerializeMessage + Sized, S: Into<String>, '_>(
    &'_ mut self,
    topic: S,
    message: T
) -> Result<SendFuture, Error>

pub async fn send_all<'a, 'b, T, S, I, '_>(
    &'_ mut self,
    topic: S,
    messages: I
) -> Result<Vec<SendFuture>, Error> where
    'b: 'a,
    T: 'b + SerializeMessage + Sized,
    I: IntoIterator<Item = T>,
    S: Into<String>,