startChunkedConversion method

@override Sink<String> startChunkedConversion(Sink<List<T>> sink)

Starts a chunked conversion.

The returned sink serves as input for the long-running conversion. The given sink serves as output.

Implementation

@override
Sink<String> startChunkedConversion(Sink<List<T>> sink) {
  return _JsonlMappedBatchDecoderSink<T>(
    sink,
    fromJson,
    jsonCodec,
    ignoreExceptions: ignoreExceptions,
    onBatch: onBatch,
    onDone: onDone,
  );
}