Struct ConnectedFileBroker 

pub struct ConnectedFileBroker { /* private fields */ }

The typed witness that connect succeeded: the file is open.

Implementations

impl ConnectedFileBroker

pub fn publisher(&self) -> FilePublisher

A publisher from the connected form.

pub async fn subscribe_stream( &self, descriptor: FileStream, ) -> Result<FileSubscriber, SeaFileError>

Opens the subscription described by descriptor.

Errors

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

Trait Implementations

impl ConnectedBroker for ConnectedFileBroker

type Error = SeaFileError

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 ConnectedFileBroker

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

Formats the value using the given formatter.

impl DefaultPublish for ConnectedFileBroker

type Policy = FilePublish

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

impl PublishPolicy<ConnectedFileBroker> for FilePublish

type Live = FilePublisher

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: &ConnectedFileBroker, ) -> Result<Self::Live, PairError>

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

impl Subscribe for ConnectedFileBroker

type Subscriber = FileSubscriber

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<ConnectedFileBroker> for FileStream

type Subscriber = FileSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

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

async fn subscribe( self, connected: &ConnectedFileBroker, ) -> Result<FileSubscriber, SeaFileError>

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