Struct PulsarPublish 

pub struct PulsarPublish;

The publish policy for PulsarPublisher: pure declaration, constructible anywhere, paired with the connected broker by the runtime after connect.

Examples

use ruststream_pulsar::PulsarPublish;

let policy = PulsarPublish::default();

Trait Implementations

impl Clone for PulsarPublish

fn clone(&self) -> PulsarPublish

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PulsarPublish

impl Debug for PulsarPublish

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

Formats the value using the given formatter.

impl Default for PulsarPublish

fn default() -> PulsarPublish

Returns the “default value” for a type.

impl PublishPolicy<ConnectedPulsarBroker> for PulsarPublish

type Live = PulsarPublisher

The live form this policy pairs into: a Publisher for a leaf policy, or the live wiring form for a combinator stack (a typed publisher over a policy pairs into the same typed publisher over the live leaf).

async fn pair( self, connected: &ConnectedPulsarBroker, ) -> Result<Self::Live, PairError>

Pairs the policy with a connected broker, producing the live publisher.