Struct flo_stream::BlockingPublisher [−][src]
pub struct BlockingPublisher<Message> { /* fields omitted */ }
Expand description
A blocking publisher is a publisher that blocks messages until it has enough subscribers
This is useful for cases where a publisher is being used asynchronously and wants to ensure that its messages are sent to at least one subscriber. Once the required number of subscribers is reached, this will not block again even if some subscribers are dropped.
Implementations
Creates a new blocking publisher
This publisher will refuse to receive any items until at least required_subscribers are connected. The buffer size indicates the number of queued items permitted per buffer.
Trait Implementations
Reserves a space for a message with the subscribers, returning when it’s ready
Waits until all subscribers have consumed all pending messages
Returns true if this publisher is closed (will not publish any further messages to its subscribers)
Future that returns when this publisher is closed
type Message = Message
Creates a subscription to this publisher Read more