Format all dart: library files

sdk/lib/io/io_sink.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.
 
 part of dart.io;
 
 /**
  * A combined byte and text output.
  *
  * An [IOSink] combines a [StreamSink] of bytes with a [StringSink],
  * and allows easy output of both bytes and text.
  *
  * Writing text ([write]) and adding bytes ([add]) may be interleaved freely.
  *
  * While a stream is being added using [addStream], any further attempts
  * to add or write to the [IOSink] will fail until the [addStream] completes.
  *
  * If data is added to the [IOSink] after the sink is closed, the data will be
  * ignored. Use the [done] future to be notified when the [IOSink] is closed.
  */
 abstract class IOSink implements StreamSink<List<int>>, StringSink {
-
   /**
    * Create an [IOSink] that outputs to a [target] [StreamConsumer] of bytes.
    *
    * Text written to [StreamSink] methods is encoded to bytes using [encoding]
    * before being output on [target].
    */
-  factory IOSink(StreamConsumer<List<int>> target,
-                 {Encoding encoding: UTF8})
-      => new _IOSinkImpl(target, encoding);
+  factory IOSink(StreamConsumer<List<int>> target, {Encoding encoding: UTF8}) =>
+      new _IOSinkImpl(target, encoding);
 
   /**
    * The [Encoding] used when writing strings. Depending on the
    * underlying consumer this property might be mutable.
    */
   Encoding encoding;
 
   /**
    * Adds byte [data] to the target consumer, ignoring [encoding].
    *
@@ skipping 117 matching lines @@
   }
 
   Future addStream(Stream<T> stream) {
     if (_isBound) {
       throw new StateError("StreamSink is already bound to a stream");
     }
     _isBound = true;
     if (_hasError) return done;
     // Wait for any sync operations to complete.
     Future targetAddStream() {
-      return _target.addStream(stream)
-          .whenComplete(() {
-            _isBound = false;
-          });
+      return _target.addStream(stream).whenComplete(() {
+        _isBound = false;
+      });
     }
+
     if (_controllerInstance == null) return targetAddStream();
     var future = _controllerCompleter.future;
     _controllerInstance.close();
     return future.then((_) => targetAddStream());
   }
 
   Future flush() {
     if (_isBound) {
       throw new StateError("StreamSink is bound to a stream");
     }
@@ skipping 67 matching lines @@
           // A new stream takes over - forward errors to that stream.
           _controllerCompleter.completeError(error, stackTrace);
           _controllerCompleter = null;
           _controllerInstance = null;
         } else {
           // No new stream. No need to close target, as it has already
           // failed.
           _completeDoneError(error, stackTrace);
         }
       });
-   }
+    }
     return _controllerInstance;
   }
 }
 
-
 class _IOSinkImpl extends _StreamSinkImpl<List<int>> implements IOSink {
   Encoding _encoding;
   bool _encodingMutable = true;
 
-  _IOSinkImpl(StreamConsumer<List<int>> target, this._encoding)
-      : super(target);
+  _IOSinkImpl(StreamConsumer<List<int>> target, this._encoding) : super(target);
 
   Encoding get encoding => _encoding;
 
   void set encoding(Encoding value) {
     if (!_encodingMutable) {
       throw new StateError("IOSink encoding is not mutable");
     }
     _encoding = value;
   }
 
@@ skipping 21 matching lines @@
 
   void writeln([Object object = ""]) {
     write(object);
     write("\n");
   }
 
   void writeCharCode(int charCode) {
     write(new String.fromCharCode(charCode));
   }
 }