stream_reader 1.0.2 copy "stream_reader: ^1.0.2" to clipboard
stream_reader: ^1.0.2 copied to clipboard

Asynchronously read from Dart streams.

stream_reader #

version 1.0.2 build status

Asynchronously read from Dart streams. Supports peeking, reading, and a reference to the current element.

Usage #

import 'dart:async';
import 'package:stream_reader/stream_reader.dart';
import 'package:test/test.dart';

Stream<String> strings() async* {
  yield 'Michael';
  yield 'Jackson';
  yield 'Bernie';
  yield 'Sanders';
}

main() {
  test('read', () async {
    // Read two
    var reader = new StreamReader<String>()..addStream(strings());
    await reader.consume();
    var str = await reader.consume();
    expect(str, equals('Jackson'));
  });

  test('peek+current', () async {
    // Read two
    var reader = new StreamReader<String>()..addStream(strings());
    await reader.consume();
    await reader.consume();
    var peek = await reader.peek();
    expect(peek, equals('Bernie'));

    // current should still be second string
    var str = await reader.current();
    expect(str, equals('Jackson'));
  });
}
0
likes
25
pub points
15%
popularity

Publisher

unverified uploader

Asynchronously read from Dart streams.

Repository (GitHub)
View/report issues

License

MIT (LICENSE)

More

Packages that depend on stream_reader