Struct MassiveAttachment 

pub struct MassiveAttachment(/* private fields */);

One stream’s view of a Massive cluster’s shared connection.

A stream of frames holding only the stream’s own subscriptions, in the order the socket delivered them, so it is parsed exactly as a socket of the stream’s own would be. It ends when the connection is lost, which is what drives the stream’s reconnect.

Dropping it detaches the stream: every subscription no other stream holds is unsubscribed, and the socket closes once nothing remains attached.

Keep it drained

The queue behind it is unbounded. The connection reads one socket for every stream sharing it, so it never waits for a slow one — that would stall the rest — and a stream it serves is not back-pressured the way a socket of its own would be. Frames for a stream that stops being polled accumulate in memory until it is polled again or dropped.

See connection for how the connection is shared.

Trait Implementations

impl Debug for MassiveAttachment

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

Formats the value using the given formatter.

impl SharedTransport for MassiveAttachment

Massive hands a stream nothing on attaching.

type Attached = ()

What the connection hands a stream on attaching, for its transformer: () for a provider with nothing to hand over.

fn take_attached(&mut self)

Take what the connection handed the stream on attaching. Called once, before any frame is read.

impl Stream for MassiveAttachment

type Item = Result<Message, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.