Index: lib/src/asset/dart/serialize/get_input_transform.dart |
diff --git a/lib/src/asset/dart/serialize/get_input_transform.dart b/lib/src/asset/dart/serialize/get_input_transform.dart |
index be22f572d918af1a54767751d713cf7ac89eb9e0..328d72d225f8df2784a622c1d9e061da81c07bdd 100644 |
--- a/lib/src/asset/dart/serialize/get_input_transform.dart |
+++ b/lib/src/asset/dart/serialize/get_input_transform.dart |
@@ -5,10 +5,9 @@ |
import 'dart:async'; |
import 'dart:convert'; |
+import 'package:async/async.dart'; |
import 'package:barback/barback.dart'; |
-import '../utils.dart'; |
- |
/// A mixin for transforms that support [getInput] and the associated suite of |
/// methods. |
abstract class GetInputTransform { |
@@ -21,7 +20,7 @@ abstract class GetInputTransform { |
} |
Stream<List<int>> readInput(AssetId id) => |
- futureStream(getInput(id).then((input) => input.read())); |
+ StreamCompleter.fromFuture(getInput(id).then((input) => input.read())); |
Future<bool> hasInput(AssetId id) { |
return getInput(id).then((_) => true).catchError((error) { |