Use pumpEventQueue() from test (#22)

pubspec.yaml

@@ -7,6 +7,6 @@ dependencies:
   stack_trace: '>=0.9.1 <2.0.0'
   stream_channel: '^1.1.0'
 dev_dependencies:
-  test: "^0.12.21"
+  test: "^0.12.28"
 environment:
   sdk: ">=1.8.0 <2.0.0"

test/client/stream_test.dart

@@ -9,8 +9,6 @@ import 'package:test/test.dart';
 
 import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc;
 
-import 'utils.dart';
-
 void main() {
   var responseController;
   var requestController;

test/client/utils.dart

@@ -54,15 +54,3 @@ class ClientController {
     _responseController.add(request);
   }
 }
-
-/// Returns a [Future] that completes after pumping the event queue [times]
-/// times. By default, this should pump the event queue enough times to allow
-/// any code to run, as long as it's not waiting on some external event.
-Future pumpEventQueue([int times = 20]) {
-  if (times == 0) return new Future.value();
-  // We use a delayed future to allow microtask events to finish. The
-  // Future.value or Future() constructors use scheduleMicrotask themselves and
-  // would therefore not wait for microtask callbacks that are scheduled after
-  // invoking this method.
-  return new Future.delayed(Duration.ZERO, () => pumpEventQueue(times - 1));
-}

test/server/stream_test.dart

@@ -9,8 +9,6 @@ import 'package:test/test.dart';
 
 import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc;
 
-import 'utils.dart';
-
 void main() {
   var requestController;
   var responseController;

test/server/utils.dart

@@ -71,15 +71,3 @@ Matcher throwsInvalidParams(String message) {
     return true;
   }));
 }
-
-/// Returns a [Future] that completes after pumping the event queue [times]
-/// times. By default, this should pump the event queue enough times to allow
-/// any code to run, as long as it's not waiting on some external event.
-Future pumpEventQueue([int times = 20]) {
-  if (times == 0) return new Future.value();
-  // We use a delayed future to allow microtask events to finish. The
-  // Future.value or Future() constructors use scheduleMicrotask themselves and
-  // would therefore not wait for microtask callbacks that are scheduled after
-  // invoking this method.
-  return new Future.delayed(Duration.ZERO, () => pumpEventQueue(times - 1));
-}