bind method

  1. @override
Stream<Iterable<Triple>> bind(
  1. Stream<String> stream
)
override

Decodes streamed N-Triples chunks while preserving blank-node identity across chunk boundaries at triple-list level.

Implementation

@override
Stream<Iterable<Triple>> bind(Stream<String> stream) async* {
  final bnodeMap = <String, BlankNodeTerm>{};
  await for (final chunk in stream) {
    yield decode(chunk, bnodeMap: bnodeMap).triples;
  }
}