| Index: lib/src/barback/barback_server.dart
|
| diff --git a/lib/src/barback/barback_server.dart b/lib/src/barback/barback_server.dart
|
| index 19082c9500a2f897f20c09efcd0fd564d36a9669..6d0a5dce65dcf6bbdb52fa9a24dcf6160f689212 100644
|
| --- a/lib/src/barback/barback_server.dart
|
| +++ b/lib/src/barback/barback_server.dart
|
| @@ -5,6 +5,7 @@
|
| import 'dart:async';
|
| import 'dart:io';
|
|
|
| +import 'package:async/async.dart';
|
| import 'package:barback/barback.dart';
|
| import 'package:mime/mime.dart';
|
| import 'package:path/path.dart' as path;
|
| @@ -156,9 +157,10 @@ class BarbackServer extends BaseServer<BarbackServerResult> {
|
| /// Returns the body of [asset] as a response to [request].
|
| Future<shelf.Response> _serveAsset(shelf.Request request, Asset asset) async {
|
| try {
|
| - var pair = tee(await validateStream(asset.read()));
|
| - var responseStream = pair.first;
|
| - var hashStream = pair.last;
|
| + var streams = StreamSplitter.splitFrom(
|
| + await validateStream(asset.read()));
|
| + var responseStream = streams.first;
|
| + var hashStream = streams.last;
|
|
|
| // Allow the asset to be cached based on its content hash.
|
| var assetSha = await sha1Stream(hashStream);
|
|
|