Function mz_compute::sink::tail::tail

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