bind method

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

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

Implementation

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