Struct mz_adapter::subscribe::PendingSubscribe

pub struct PendingSubscribe {
    pub session_type: &'static str,
    pub channel: UnboundedSender<PeekResponseUnary>,
    pub emit_progress: bool,
    pub arity: usize,
}

A description of a pending subscribe from coord’s perspective

Fields

session_type: &'static str

The type of the session that created the subscribe.

channel: UnboundedSender<PeekResponseUnary>

Channel to send responses to the client

The responses have the form PeekResponseUnary but should perhaps become TailResponse.

emit_progress: bool

Whether progress information should be emitted

arity: usize

Number of columns in the output

Implementations

impl PendingSubscribe

pub(crate) fn process_response(&mut self, response: SubscribeResponse) -> bool

Process a subscribe response

Returns true if the sink should be removed.