Skip to content

Commit

Permalink
http revert
Browse files Browse the repository at this point in the history
  • Loading branch information
krukow committed Nov 4, 2011
1 parent 1d186d1 commit 7d3610a
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion src/http.dart
Expand Up @@ -3,7 +3,7 @@
// BSD-style license that can be found in the LICENSE file.

#library("http");
#source("http/http_impl.dart");
#source("http_impl.dart");

/**
* HTTP status codes.
Expand Down
12 changes: 6 additions & 6 deletions src/http/http_impl.dart
Expand Up @@ -928,9 +928,9 @@ class HTTPConnectionBase {
: _sendBuffers = new Queue(),
_httpParser = new HTTPParser() {
// Register handler for socket events.
_socket.setDataHandler(() => _dataHandler());
_socket.setCloseHandler(() => _closeHandler());
_socket.setErrorHandler(() => _errorHandler());
_socket.dataHandler = _dataHandler;
_socket.closeHandler = _closeHandler;
_socket.errorHandler = _errorHandler;
}

// Add data to be send. If the flag keepBuffer is false (the
Expand Down Expand Up @@ -980,7 +980,7 @@ class HTTPConnectionBase {

// If all data has been sent notify the callback.
if (_sendBuffers.isEmpty() && callback != null) {
_socket.setWriteHandler(null);
_socket.writeHandler = null;
callback();
}
}
Expand All @@ -990,7 +990,7 @@ class HTTPConnectionBase {
SendBuffer buffer = _sendBuffers.first();
buffer._write(_socket);
if (!buffer._isSent) {
_socket.setWriteHandler(continueSending);
_socket.writeHandler = continueSending;
break;
} else {
_sendBuffers.removeFirst();
Expand Down Expand Up @@ -1126,7 +1126,7 @@ class HTTPServerImplementation implements HTTPServer {
_connections = new Queue<HTTPConnection>();
_connectionsCount = 0;
_server = new ServerSocket(host, port, 5);
_server.setConnectionHandler(connectionHandler);
_server.connectionHandler = connectionHandler;
}

void close() => _server.close();
Expand Down

0 comments on commit 7d3610a

Please sign in to comment.