Index: samples/chat/chat_server_lib.dart |
diff --git a/samples/chat/chat_server_lib.dart b/samples/chat/chat_server_lib.dart |
index 6dc550043a1917075568df373c150344ea56475d..833755cb4cf55b2545f32f0b0f97c9a7c86a7ef0 100644 |
--- a/samples/chat/chat_server_lib.dart |
+++ b/samples/chat/chat_server_lib.dart |
@@ -409,8 +409,8 @@ class IsolatedServer extends Isolate { |
void _joinHandler(HttpRequest request, HttpResponse response) { |
StringBuffer body = new StringBuffer(); |
StringInputStream input = new StringInputStream(request.inputStream); |
- input.dataHandler = () => body.add(input.read()); |
- input.closeHandler = () { |
+ input.onData = () => body.add(input.read()); |
+ input.onClosed = () { |
String data = body.toString(); |
if (data != null) { |
var requestData = JSON.parse(data); |
@@ -443,8 +443,8 @@ class IsolatedServer extends Isolate { |
void _leaveHandler(HttpRequest request, HttpResponse response) { |
StringBuffer body = new StringBuffer(); |
StringInputStream input = new StringInputStream(request.inputStream); |
- input.dataHandler = () => body.add(input.read()); |
- input.closeHandler = () { |
+ input.onData = () => body.add(input.read()); |
+ input.onClosed = () { |
String data = body.toString(); |
var requestData = JSON.parse(data); |
if (requestData["request"] == "leave") { |
@@ -473,8 +473,8 @@ class IsolatedServer extends Isolate { |
void _messageHandler(HttpRequest request, HttpResponse response) { |
StringBuffer body = new StringBuffer(); |
StringInputStream input = new StringInputStream(request.inputStream); |
- input.dataHandler = () => body.add(input.read()); |
- input.closeHandler = () { |
+ input.onData = () => body.add(input.read()); |
+ input.onClosed = () { |
String data = body.toString(); |
_messageCount++; |
_messageRate.record(1); |
@@ -510,8 +510,8 @@ class IsolatedServer extends Isolate { |
void _receiveHandler(HttpRequest request, HttpResponse response) { |
StringBuffer body = new StringBuffer(); |
StringInputStream input = new StringInputStream(request.inputStream); |
- input.dataHandler = () => body.add(input.read()); |
- input.closeHandler = () { |
+ input.onData = () => body.add(input.read()); |
+ input.onClosed = () { |
String data = body.toString(); |
var requestData = JSON.parse(data); |
if (requestData["request"] == "receive") { |
@@ -587,7 +587,7 @@ class IsolatedServer extends Isolate { |
_server = new HttpServer(); |
try { |
_server.listen(_host, _port, backlog: message.backlog); |
- _server.requestHandler = (HttpRequest req, HttpResponse rsp) => |
+ _server.onRequest = (HttpRequest req, HttpResponse rsp) => |
_requestReceivedHandler(req, rsp); |
replyTo.send(new ChatServerStatus.started(_server.port), null); |
_loggingTimer = new Timer.repeating(_handleLogging, 1000); |