org.chromium.sdk/src/org/chromium/sdk/internal/transport/Handshaker.java
changeset 52 f577ea64429e
parent 2 e4420d2515f1
child 56 22f918ed49f7
--- a/org.chromium.sdk/src/org/chromium/sdk/internal/transport/Handshaker.java	Wed Jan 27 10:42:14 2010 -0800
+++ b/org.chromium.sdk/src/org/chromium/sdk/internal/transport/Handshaker.java	Wed Jan 27 15:45:27 2010 -0800
@@ -4,7 +4,6 @@
 
 package org.chromium.sdk.internal.transport;
 
-import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.Writer;
 import java.util.concurrent.Callable;
@@ -13,6 +12,7 @@
 import java.util.concurrent.FutureTask;
 import java.util.concurrent.RunnableFuture;
 
+import org.chromium.sdk.LineReader;
 import org.chromium.sdk.internal.transport.Message.MalformedMessageException;
 
 /**
@@ -27,14 +27,14 @@
    * @throws IOException if handshake process failed physically (input or output has unexpectedly
    * closed) or logically (if unexpected message came from remote).
    */
-  void perform(BufferedReader input, Writer output) throws IOException;
+  void perform(LineReader input, Writer output) throws IOException;
 
   /**
    * Implementation of handshake from Google Chrome Developer Tools Protocol. Used when we
    * connect to browser.
    */
   Handshaker CHROMIUM = new Handshaker() {
-    public void perform(BufferedReader input, Writer output) throws IOException {
+    public void perform(LineReader input, Writer output) throws IOException {
       output.write(OUTGOING_MESSAGE);
       output.flush();
 
@@ -88,9 +88,9 @@
     private final RunnableFuture<RemoteInfo> runnableFuture =
         new FutureTask<RemoteInfo>(new HandshakeTaks());
 
-    private BufferedReader input = null;
+    private LineReader input = null;
 
-    public void perform(BufferedReader input, Writer output) throws IOException {
+    public void perform(LineReader input, Writer output) throws IOException {
       this.input = input;
       runnableFuture.run();