Function render_completion_operator

pub fn render_completion_operator<G, F>(
    scope: G,
    results_stream: &Stream<G, Result<ProtoBatch, StorageErrorX>>,
    worker_callback: F,
)
where
    G: Scope,
    F: FnOnce(Result<Option<ProtoBatch>, String>) + 'static,

Render an operator that given a stream of ProtoBatches will call our worker_callback to report the results upstream.