Struct ConnectedPulsarBroker 

pub struct ConnectedPulsarBroker { /* private fields */ }

The typed witness that connect succeeded: holds the live client directly.

Implementations

impl ConnectedPulsarBroker

pub fn publisher(&self) -> PulsarPublisher

A publisher from the connected form. It rides the same cell-backed publisher type as the early path; by now connect has filled the cell, so it resolves immediately.

pub async fn subscribe_descriptor( &self, descriptor: PulsarSubscription, ) -> Result<PulsarSubscriber, PulsarError>

Opens the subscription described by descriptor.

Errors

Returns PulsarError when the descriptor is invalid, the consumer cannot be created, or the broker is shut down.

Trait Implementations

impl ConnectedBroker for ConnectedPulsarBroker

type Error = PulsarError

The error type returned by connected-broker operations.

type Closed = ()

The terminal witness returned by shutdown.

async fn shutdown(self) -> Result<(), Self::Error>

Closes the broker connection, flushing in-flight publishes and stopping background tasks, consuming the connected form.

impl Debug for ConnectedPulsarBroker

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

Formats the value using the given formatter.

impl DefaultPublish for ConnectedPulsarBroker

type Policy = PulsarPublish

The broker’s plain publish policy, constructible with its defaults.

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.

impl Subscribe for ConnectedPulsarBroker

type Subscriber = PulsarSubscriber

The subscriber type opened by a by-name subscription.

async fn subscribe(&self, name: &str) -> Result<Self::Subscriber, Self::Error>

Opens a subscription to name, producing this broker’s Subscriber.

impl SubscriptionSource<ConnectedPulsarBroker> for PulsarSubscription

type Subscriber = PulsarSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, connected: &ConnectedPulsarBroker, ) -> Result<PulsarSubscriber, PulsarError>

Opens the subscription against the connected broker. Called once at startup.