Rename unsubscribe to cancel.

sdk/lib/async/stream_pipe.dart

 // Copyright (c) 2012, 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.
 
 // part of dart.async;
 
 /**
  * A pipe between two streams.
  *
  * The default pipe subscribes to the [source] and sends on the
  * [stream].
  *
  * The events are passed through the [_handleData], [_handleError] and
  * [_handleDone] methods. Subclasses are supposed to add handling of some of
  * the events by overriding these methods.
  *
  * This class is intended for internal use only. Users can use the [PipeStream]
  * to configure similar behavior.
  */
 abstract class _ForwardingStream<S, T> extends _MultiStreamImpl<T>
                                        implements StreamChain<S, T> {
   Stream<S> _source = null;
   StreamSubscription _subscription = null;
 
   StreamController<T> _createController() {
     return new _BaseForwardingController<T>(this);
   }
 
   void _subscribeToSource() {
-    _subscription = _source.subscribe(onData: this._handleData,
-                                      onError: this._handleError,
-                                      onDone: this._handleDone);
+    _subscription = _source.listen(this._handleData,
+                                   onError: this._handleError,
+                                   onDone: this._handleDone);
     if (_isPaused) {
       _subscription.pause();
     }
   }
 
   Stream<T> bind(Stream<S> source) {
     assert(_source == null);
     _source = source;
     if (_hasSubscribers) {
       _subscribeToSource();
     }
     return this;
   }
 
   /**
     * Subscribe or unsubscribe on [source] depending on whether
     * [stream] has subscribers.
     */
   void _onSubscriptionStateChange() {
     if (_hasSubscribers) {
       assert(_subscription == null);
       if (_source != null) {
         _subscribeToSource();
       }
     } else {
       if (_subscription != null) {
-        _subscription.unsubscribe();
+        _subscription.cancel();
         _subscription = null;
       }
     }
   }
 
   void _onPauseStateChange() {
     if (_subscription == null) return;
     if (isPaused) {
       _subscription.pause();
     } else {
@@ skipping 381 matching lines @@
         _signalError(new AsyncError(e, s));
         return null;
       }
       if (!isEqual) {
         _add(inputEvent);
         _previous = inputEvent;
       }
     }
   }
 }