Function dataflow::sink::tail::tail

fn tail<G>(
    sinked_collection: Collection<G, (Option<Row>, Option<Row>), Diff>, 
    sink_id: GlobalId, 
    as_of: SinkAsOf, 
    tail_protocol_handle: Rc<RefCell<Option<TailProtocol>>>, 
    active_worker: bool
) where
    G: Scope<Timestamp = Timestamp>,