| Index: packages/quiver/test/async/stream_buffer_test.dart
|
| diff --git a/packages/quiver/test/streams/streambuffer_test.dart b/packages/quiver/test/async/stream_buffer_test.dart
|
| similarity index 81%
|
| rename from packages/quiver/test/streams/streambuffer_test.dart
|
| rename to packages/quiver/test/async/stream_buffer_test.dart
|
| index d2a74b7de70e9050f09b42468e3ecf77fa0b486d..f2dd7b8c55a5d90ce5808a2f0b7cce140d6629d2 100644
|
| --- a/packages/quiver/test/streams/streambuffer_test.dart
|
| +++ b/packages/quiver/test/async/stream_buffer_test.dart
|
| @@ -12,17 +12,21 @@
|
| // See the License for the specific language governing permissions and
|
| // limitations under the License.
|
|
|
| -library quiver.streams.streambuffer_test;
|
| +library quiver.async.stream_buffer_test;
|
|
|
| import 'dart:async';
|
| import 'package:test/test.dart';
|
| -import 'package:quiver/streams.dart';
|
| +import 'package:quiver/async.dart';
|
|
|
| void main() {
|
| group("StreamBuffer", () {
|
| test("returns orderly overlaps", () {
|
| - StreamBuffer<int> buf = new StreamBuffer();
|
| - new Stream.fromIterable([[1], [2, 3, 4], [5, 6, 7, 8]]).pipe(buf);
|
| + StreamBuffer<List<int>> buf = new StreamBuffer();
|
| + new Stream.fromIterable([
|
| + [1],
|
| + [2, 3, 4],
|
| + [5, 6, 7, 8]
|
| + ]).pipe(buf);
|
| return Future.wait([buf.read(2), buf.read(4), buf.read(2)]).then((vals) {
|
| expect(vals[0], equals([1, 2]));
|
| expect(vals[1], equals([3, 4, 5, 6]));
|
| @@ -33,8 +37,13 @@ void main() {
|
| });
|
|
|
| test("respects pausing of stream", () {
|
| - StreamBuffer<int> buf = new StreamBuffer()..limit = 2;
|
| - new Stream.fromIterable([[1], [2], [3], [4]]).pipe(buf);
|
| + StreamBuffer<List<int>> buf = new StreamBuffer()..limit = 2;
|
| + new Stream.fromIterable([
|
| + [1],
|
| + [2],
|
| + [3],
|
| + [4]
|
| + ]).pipe(buf);
|
| return buf.read(2).then((val) {
|
| expect(val, [1, 2]);
|
| }).then((_) {
|
| @@ -45,8 +54,11 @@ void main() {
|
| });
|
|
|
| test("throws when reading too much", () {
|
| - StreamBuffer<int> buf = new StreamBuffer()..limit = 1;
|
| - new Stream.fromIterable([[1], [2]]).pipe(buf);
|
| + StreamBuffer<List<int>> buf = new StreamBuffer()..limit = 1;
|
| + new Stream.fromIterable([
|
| + [1],
|
| + [2]
|
| + ]).pipe(buf);
|
| try {
|
| buf.read(2);
|
| } catch (e) {
|
|
|