Format all dart: library files

sdk/lib/io/secure_server_socket.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.io;
 
 /**
  * The [SecureServerSocket] is a server socket, providing a stream of high-level
  * [Socket]s.
  *
@@ skipping 44 matching lines @@
    *
    * The optional argument [shared] specifies whether additional
    * SecureServerSocket objects can bind to the same combination of `address`,
    * `port` and `v6Only`.  If `shared` is `true` and more `SecureServerSocket`s
    * from this isolate or other isolates are bound to the port, then the
    * incoming connections will be distributed among all the bound
    * `SecureServerSocket`s. Connections can be distributed over multiple
    * isolates this way.
    */
   static Future<SecureServerSocket> bind(
-      address,
-      int port,
-      SecurityContext context,
+      address, int port, SecurityContext context,
       {int backlog: 0,
-       bool v6Only: false,
-       bool requestClientCertificate: false,
-       bool requireClientCertificate: false,
-       List<String> supportedProtocols,
-       bool shared: false}) {
-    return RawSecureServerSocket.bind(
-        address,
-        port,
-        context,
-        backlog: backlog,
-        v6Only: v6Only,
-        requestClientCertificate: requestClientCertificate,
-        requireClientCertificate: requireClientCertificate,
-        supportedProtocols: supportedProtocols,
-        shared: shared).then(
-            (serverSocket) => new SecureServerSocket._(serverSocket));
+      bool v6Only: false,
+      bool requestClientCertificate: false,
+      bool requireClientCertificate: false,
+      List<String> supportedProtocols,
+      bool shared: false}) {
+    return RawSecureServerSocket
+        .bind(address, port, context,
+            backlog: backlog,
+            v6Only: v6Only,
+            requestClientCertificate: requestClientCertificate,
+            requireClientCertificate: requireClientCertificate,
+            supportedProtocols: supportedProtocols,
+            shared: shared)
+        .then((serverSocket) => new SecureServerSocket._(serverSocket));
   }
 
   StreamSubscription<SecureSocket> listen(void onData(SecureSocket socket),
-                                          {Function onError,
-                                           void onDone(),
-                                           bool cancelOnError}) {
-    return _socket.map((rawSocket) => new SecureSocket._(rawSocket))
-                  .listen(onData,
-                          onError: onError,
-                          onDone: onDone,
-                          cancelOnError: cancelOnError);
+      {Function onError, void onDone(), bool cancelOnError}) {
+    return _socket.map((rawSocket) => new SecureSocket._(rawSocket)).listen(
+        onData,
+        onError: onError,
+        onDone: onDone,
+        cancelOnError: cancelOnError);
   }
 
   /**
    * Returns the port used by this socket.
    */
   int get port => _socket.port;
 
   /**
    * Returns the address used by this socket.
    */
   InternetAddress get address => _socket.address;
 
   /**
    * Closes the socket. The returned future completes when the socket
    * is fully closed and is no longer bound.
    */
   Future<SecureServerSocket> close() => _socket.close().then((_) => this);
 
-  void set _owner(owner) { _socket._owner = owner; }
+  void set _owner(owner) {
+    _socket._owner = owner;
+  }
 }
 
-
 /**
  * The RawSecureServerSocket is a server socket, providing a stream of low-level
  * [RawSecureSocket]s.
  *
  * See [RawSecureSocket] for more info.
  */
 class RawSecureServerSocket extends Stream<RawSecureSocket> {
   final RawServerSocket _socket;
   StreamController<RawSecureSocket> _controller;
   StreamSubscription<RawSocket> _subscription;
   final SecurityContext _context;
   final bool requestClientCertificate;
   final bool requireClientCertificate;
   final List<String> supportedProtocols;
   bool _closed = false;
 
-  RawSecureServerSocket._(this._socket,
-                          this._context,
-                          this.requestClientCertificate,
-                          this.requireClientCertificate,
-                          this.supportedProtocols) {
+  RawSecureServerSocket._(
+      this._socket,
+      this._context,
+      this.requestClientCertificate,
+      this.requireClientCertificate,
+      this.supportedProtocols) {
     _controller = new StreamController<RawSecureSocket>(
         sync: true,
         onListen: _onSubscriptionStateChange,
         onPause: _onPauseStateChange,
         onResume: _onPauseStateChange,
         onCancel: _onSubscriptionStateChange);
   }
 
   /**
    * Returns a future for a [RawSecureServerSocket]. When the future
@@ skipping 34 matching lines @@
    *
    * The optional argument [shared] specifies whether additional
    * RawSecureServerSocket objects can bind to the same combination of
    * `address`, `port` and `v6Only`.  If `shared` is `true` and more
    * `RawSecureServerSocket`s from this isolate or other isolates are bound to
    * the port, then the incoming connections will be distributed among all the
    * bound `RawSecureServerSocket`s. Connections can be distributed over
    * multiple isolates this way.
    */
   static Future<RawSecureServerSocket> bind(
-      address,
-      int port,
-      SecurityContext context,
+      address, int port, SecurityContext context,
       {int backlog: 0,
-       bool v6Only: false,
-       bool requestClientCertificate: false,
-       bool requireClientCertificate: false,
-       List<String> supportedProtocols,
-       bool shared: false}) {
-    return RawServerSocket.bind(
-        address, port, backlog: backlog, v6Only: v6Only, shared: shared)
+      bool v6Only: false,
+      bool requestClientCertificate: false,
+      bool requireClientCertificate: false,
+      List<String> supportedProtocols,
+      bool shared: false}) {
+    return RawServerSocket
+        .bind(address, port, backlog: backlog, v6Only: v6Only, shared: shared)
         .then((serverSocket) => new RawSecureServerSocket._(
             serverSocket,
             context,
             requestClientCertificate,
             requireClientCertificate,
             supportedProtocols));
   }
 
   StreamSubscription<RawSecureSocket> listen(void onData(RawSecureSocket s),
-                                             {Function onError,
-                                              void onDone(),
-                                              bool cancelOnError}) {
+      {Function onError, void onDone(), bool cancelOnError}) {
     return _controller.stream.listen(onData,
-                                     onError: onError,
-                                     onDone: onDone,
-                                     cancelOnError: cancelOnError);
+        onError: onError, onDone: onDone, cancelOnError: cancelOnError);
   }
 
   /**
    * Returns the port used by this socket.
    */
   int get port => _socket.port;
 
   /**
    * Returns the address used by this socket.
    */
@@ skipping 10 matching lines @@
 
   void _onData(RawSocket connection) {
     var remotePort;
     try {
       remotePort = connection.remotePort;
     } catch (e) {
       // If connection is already closed, remotePort throws an exception.
       // Do nothing - connection is closed.
       return;
     }
-    _RawSecureSocket.connect(
-        connection.address,
-        remotePort,
-        context: _context,
-        is_server: true,
-        socket: connection,
-        requestClientCertificate: requestClientCertificate,
-        requireClientCertificate: requireClientCertificate,
-        supportedProtocols: supportedProtocols)
-    .then((RawSecureSocket secureConnection) {
+    _RawSecureSocket
+        .connect(connection.address, remotePort,
+            context: _context,
+            is_server: true,
+            socket: connection,
+            requestClientCertificate: requestClientCertificate,
+            requireClientCertificate: requireClientCertificate,
+            supportedProtocols: supportedProtocols)
+        .then((RawSecureSocket secureConnection) {
       if (_closed) {
         secureConnection.close();
       } else {
         _controller.add(secureConnection);
       }
     }).catchError((e, s) {
       if (!_closed) {
         _controller.addError(e, s);
       }
     });
   }
 
   void _onPauseStateChange() {
     if (_controller.isPaused) {
       _subscription.pause();
     } else {
       _subscription.resume();
     }
   }
 
   void _onSubscriptionStateChange() {
     if (_controller.hasListener) {
       _subscription = _socket.listen(_onData,
-                                     onError: _controller.addError,
-                                     onDone: _controller.close);
+          onError: _controller.addError, onDone: _controller.close);
     } else {
       close();
     }
   }
 
   void set _owner(owner) {
     (_socket as dynamic)._owner = owner;
   }
 }
-
-