Support shelf 0.7.0.

lib/src/utils.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:math' as math;
 
 import 'package:async/async.dart' hide StreamQueue;
 import 'package:crypto/crypto.dart';
@@ skipping 190 matching lines @@
   var result = {};
   map1.forEach((key, value) {
     result[key] = value;
   });
   map2.forEach((key, value) {
     result[key] = value;
   });
   return result;
 }
 
-/// Returns a sink that maps events sent to [original] using [fn].
-StreamSink mapSink(StreamSink original, fn(event)) {
-  var controller = new StreamController(sync: true);
-  controller.stream.listen(
-      (event) => original.add(fn(event)),
-      onError: (error, stackTrace) => original.addError(error, stackTrace),
-      onDone: () => original.close());
-  return controller.sink;
-}
-
 /// Like [runZoned], but [zoneValues] are set for the callbacks in
 /// [zoneSpecification] and [onError].
 runZonedWithValues(body(), {Map zoneValues,
     ZoneSpecification zoneSpecification, Function onError}) {
   return runZoned(() {
     return runZoned(body,
         zoneSpecification: zoneSpecification, onError: onError);
   }, zoneValues: zoneValues);
 }
 
@@ skipping 188 matching lines @@
       urlSafe: urlSafe, addLineSeparator: addLineSeparator);
 }
 
 /// Returns middleware that nests all requests beneath the URL prefix [beneath].
 shelf.Middleware nestingMiddleware(String beneath) {
   return (handler) {
     var pathHandler = new PathHandler()..add(beneath, handler);
     return pathHandler.handler;
   };
 }