1 files changed, 48 insertions, 18 deletions
diff --git a/AndroidAsyncTest/src/com/koushikdutta/async/test/SocketIOTests.java b/AndroidAsyncTest/src/com/koushikdutta/async/test/SocketIOTests.java
index 4037250..e2ba96c 100644
--- a/AndroidAsyncTest/src/com/koushikdutta/async/test/SocketIOTests.java
+++ b/AndroidAsyncTest/src/com/koushikdutta/async/test/SocketIOTests.java
@@ -2,7 +2,9 @@ package com.koushikdutta.async.test;
 
 import java.util.concurrent.TimeUnit;
 
+import junit.framework.Assert;
 import junit.framework.TestCase;
+import android.os.Handler;
 
 import com.koushikdutta.async.future.SimpleFuture;
 import com.koushikdutta.async.http.AsyncHttpClient;
@@ -20,24 +22,24 @@ public class SocketIOTests extends TestCase {
         }
     }
     
-    public void testChannels() throws Exception {
-        final TriggerFuture trigger = new TriggerFuture();
-        SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), "http://192.168.1.2:3000/chat", new SocketIOConnectCallback() {
-            @Override
-            public void onConnectCompleted(Exception ex, SocketIOClient client) {
-                assertNull(ex);
-                client.setStringCallback(new StringCallback() {
-                    @Override
-                    public void onString(String string) {
-                        trigger.trigger("hello".equals(string));
-                    }
-                });
-                client.emit("hello");
-            }
-        });
-        assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
-
-    }
+//    public void testChannels() throws Exception {
+//        final TriggerFuture trigger = new TriggerFuture();
+//        SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), "http://koush.clockworkmod.com/chat", new SocketIOConnectCallback() {
+//            @Override
+//            public void onConnectCompleted(Exception ex, SocketIOClient client) {
+//                assertNull(ex);
+//                client.setStringCallback(new StringCallback() {
+//                    @Override
+//                    public void onString(String string) {
+//                        trigger.trigger("hello".equals(string));
+//                    }
+//                });
+//                client.emit("hello");
+//            }
+//        });
+//        assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
+//
+//    }
     
     public void testEchoServer() throws Exception {
         final TriggerFuture trigger = new TriggerFuture();
@@ -59,4 +61,32 @@ public class SocketIOTests extends TestCase {
         assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
     }
 
+//    public void testReconnect() throws Exception {
+//        final TriggerFuture trigger = new TriggerFuture();
+//
+//
+//        SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), "http://koush.clockworkmod.com:8080", new SocketIOConnectCallback() {
+//            @Override
+//            public void onConnectCompleted(Exception ex, final SocketIOClient oldClient) {
+//                assertNull(ex);
+//                oldClient.disconnect();
+//                oldClient.reconnect(new SocketIOConnectCallback() {
+//                    @Override
+//                    public void onConnectCompleted(Exception ex, SocketIOClient client) {
+//                        assertNull(ex);
+//                        assertEquals(client, oldClient);
+//                        client.setStringCallback(new StringCallback() {
+//                            @Override
+//                            public void onString(String string) {
+//                                trigger.trigger("hello".equals(string));
+//                            }
+//                        });
+//                        client.emit("hello");
+//                    }
+//                });
+//            }
+//        });
+//
+//        assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
+//    }
 }