diff options
Diffstat (limited to 'AndroidAsyncTest/src')
| -rw-r--r-- | AndroidAsyncTest/src/com/koushikdutta/async/test/SocketIOTests.java | 66 |
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)); +// } } |