jsonlEncodeBatchAsync<T> function

Future<void> jsonlEncodeBatchAsync<T>({
  1. required Stream<List<T>> batches,
  2. StringSink? sink,
  3. StringSink sinkProvider()?,
})

Implementation

Future<void> jsonlEncodeBatchAsync<T>({
  required Stream<List<T>> batches,
  StringSink? sink,
  StringSink Function()? sinkProvider,
}) {
  return encodeBatchAsync(
    batches: batches,
    encodeAsync: (items, sink) => jsonlEncodeAsync(items: items, sink: sink),
    sink: sink,
    sinkProvider: sinkProvider,
  );
}