pub fn render_split_work<G, S, F>(
scope: G,
collection_id: GlobalId,
objects: &Stream<G, Result<(S::Object, S::Checksum), StorageErrorX>>,
source: S,
format: F,
) -> (Stream<G, Result<F::WorkRequest<S>, StorageErrorX>>, PressOnDropButton)
Expand description
Render an operator that given a stream of OneshotSource::Object
s will split them into units
of work based on the provided OneshotFormat
.