Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(90)

Side by Side Diff: sdk/lib/io/http_impl.dart

Issue 12380029: Keep track of closing socket, in WebSocket, so we don't write once the socket is closed. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « no previous file | sdk/lib/io/websocket_impl.dart » ('j') | sdk/lib/io/websocket_impl.dart » ('J')
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 part of dart.io; 5 part of dart.io;
6 6
7 class _HttpIncoming 7 class _HttpIncoming
8 extends Stream<List<int>> implements StreamSink<List<int>> { 8 extends Stream<List<int>> implements StreamSink<List<int>> {
9 final int _transferLength; 9 final int _transferLength;
10 final Completer _dataCompleter = new Completer(); 10 final Completer _dataCompleter = new Completer();
(...skipping 1485 matching lines...) Expand 10 before | Expand all | Expand 10 after
1496 return _socket.addStream(stream); 1496 return _socket.addStream(stream);
1497 } 1497 }
1498 1498
1499 void addString(String string, [Encoding encoding = Encoding.UTF_8]) { 1499 void addString(String string, [Encoding encoding = Encoding.UTF_8]) {
1500 return _socket.addString(string, encoding); 1500 return _socket.addString(string, encoding);
1501 } 1501 }
1502 1502
1503 void destroy() => _socket.destroy(); 1503 void destroy() => _socket.destroy();
1504 void add(List<int> data) => _socket.add(data); 1504 void add(List<int> data) => _socket.add(data);
1505 Future<Socket> close() => _socket.close(); 1505 Future<Socket> close() => _socket.close();
1506 Future<Socket> get done => _socket.done;
1506 } 1507 }
1507 1508
1508 1509
1509 class _AuthenticationScheme { 1510 class _AuthenticationScheme {
1510 static const UNKNOWN = const _AuthenticationScheme(-1); 1511 static const UNKNOWN = const _AuthenticationScheme(-1);
1511 static const BASIC = const _AuthenticationScheme(0); 1512 static const BASIC = const _AuthenticationScheme(0);
1512 static const DIGEST = const _AuthenticationScheme(1); 1513 static const DIGEST = const _AuthenticationScheme(1);
1513 1514
1514 const _AuthenticationScheme(this._scheme); 1515 const _AuthenticationScheme(this._scheme);
1515 1516
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
1611 1612
1612 1613
1613 class _RedirectInfo implements RedirectInfo { 1614 class _RedirectInfo implements RedirectInfo {
1614 const _RedirectInfo(int this.statusCode, 1615 const _RedirectInfo(int this.statusCode,
1615 String this.method, 1616 String this.method,
1616 Uri this.location); 1617 Uri this.location);
1617 final int statusCode; 1618 final int statusCode;
1618 final String method; 1619 final String method;
1619 final Uri location; 1620 final Uri location;
1620 } 1621 }
OLDNEW
« no previous file with comments | « no previous file | sdk/lib/io/websocket_impl.dart » ('j') | sdk/lib/io/websocket_impl.dart » ('J')

Powered by Google App Engine
This is Rietveld 408576698