StreamChannel bind()

in lib/src/json_document_transformer.dart [27:34]

• 8 lines of code
• 1 McCabe index (conditional complexity)

  StreamChannel<Object?> bind(StreamChannel<String> channel) {
    var stream = channel.stream.map(jsonDecode);
    var sink = StreamSinkTransformer<Object, String>.fromHandlers(
        handleData: (data, sink) {
      sink.add(jsonEncode(data));
    }).bind(channel.sink);
    return StreamChannel.withCloseGuarantee(stream, sink);
  }