Struct dataflow::sink::tail::TailProtocol [−][src]
struct TailProtocol {
pub sink_id: GlobalId,
pub tail_response_buffer: Option<Rc<RefCell<Vec<(GlobalId, TailResponse)>>>>,
}
Expand description
A type that guides the transmission of rows back to the coordinator.
A protocol instance may send
rows indefinitely, and is consumed by complete
,
which is used only to indicate the end of a stream. The Drop
implementation
otherwise sends an indication that the protocol has finished without completion.
Fields
sink_id: GlobalId
tail_response_buffer: Option<Rc<RefCell<Vec<(GlobalId, TailResponse)>>>>
Implementations
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for TailProtocol
impl !Send for TailProtocol
impl !Sync for TailProtocol
impl Unpin for TailProtocol
impl !UnwindSafe for TailProtocol
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more