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

Side by Side Diff: runtime/bin/http_impl.dart

Issue 9969202: Add method flush to output stream (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 8 years, 8 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
OLDNEW
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2012, 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 class _HttpHeaders implements HttpHeaders { 5 class _HttpHeaders implements HttpHeaders {
6 _HttpHeaders() : _headers = new Map<String, List<String>>(); 6 _HttpHeaders() : _headers = new Map<String, List<String>>();
7 7
8 List<String> operator[](String name) { 8 List<String> operator[](String name) {
9 name = name.toLowerCase(); 9 name = name.toLowerCase();
10 return _headers[name]; 10 return _headers[name];
(...skipping 562 matching lines...) Expand 10 before | Expand all | Expand 10 after
573 _HttpOutputStream(_HttpRequestResponseBase this._requestOrResponse); 573 _HttpOutputStream(_HttpRequestResponseBase this._requestOrResponse);
574 574
575 bool write(List<int> buffer, [bool copyBuffer = true]) { 575 bool write(List<int> buffer, [bool copyBuffer = true]) {
576 return _requestOrResponse._streamWrite(buffer, copyBuffer); 576 return _requestOrResponse._streamWrite(buffer, copyBuffer);
577 } 577 }
578 578
579 bool writeFrom(List<int> buffer, [int offset = 0, int len]) { 579 bool writeFrom(List<int> buffer, [int offset = 0, int len]) {
580 return _requestOrResponse._streamWriteFrom(buffer, offset, len); 580 return _requestOrResponse._streamWriteFrom(buffer, offset, len);
581 } 581 }
582 582
583 void flush() {
584 // Nothing to do on a HTTP output stream.
585 }
586
583 void close() { 587 void close() {
584 _requestOrResponse._streamClose(); 588 _requestOrResponse._streamClose();
585 } 589 }
586 590
587 void destroy() { 591 void destroy() {
588 throw "Not implemented"; 592 throw "Not implemented";
589 } 593 }
590 594
591 void set onNoPendingWrites(void callback()) { 595 void set onNoPendingWrites(void callback()) {
592 _requestOrResponse._streamSetNoPendingWriteHandler(callback); 596 _requestOrResponse._streamSetNoPendingWriteHandler(callback);
(...skipping 737 matching lines...) Expand 10 before | Expand all | Expand 10 after
1330 sockets.addFirst(socketConn); 1334 sockets.addFirst(socketConn);
1331 socketConn._markReturned(); 1335 socketConn._markReturned();
1332 } 1336 }
1333 1337
1334 Function _onOpen; 1338 Function _onOpen;
1335 Map<String, Queue<_SocketConnection>> _openSockets; 1339 Map<String, Queue<_SocketConnection>> _openSockets;
1336 Set<_SocketConnection> _activeSockets; 1340 Set<_SocketConnection> _activeSockets;
1337 Timer _evictionTimer; 1341 Timer _evictionTimer;
1338 bool _shutdown; // Has this HTTP client been shutdown? 1342 bool _shutdown; // Has this HTTP client been shutdown?
1339 } 1343 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698