aboutsummaryrefslogtreecommitdiffstats
path: root/README.md
diff options
context:
space:
mode:
authorpaulpdaniels <paulpdaniels@gmail.com>2014-04-18 12:18:48 -0700
committerpaulpdaniels <paulpdaniels@gmail.com>2014-04-18 12:18:48 -0700
commitdb72f5050ddf362e4c6c871ce2201db665a78403 (patch)
treeda7c96432a1896ab8d3ae251e2d03d9b61b21644 /README.md
parent22f5da0f37e943cdd31381c5f9f135df4cbeb3fb (diff)
downloadAndroidAsync-db72f5050ddf362e4c6c871ce2201db665a78403.tar.gz
AndroidAsync-db72f5050ddf362e4c6c871ce2201db665a78403.tar.bz2
AndroidAsync-db72f5050ddf362e4c6c871ce2201db665a78403.zip
Update README.md
Added sample code from #136
Diffstat (limited to 'README.md')
-rw-r--r--README.md37
1 files changed, 36 insertions, 1 deletions
diff --git a/README.md b/README.md
index 11449b9..833dbb0 100644
--- a/README.md
+++ b/README.md
@@ -195,16 +195,51 @@ AsyncHttpClient.getDefaultInstance().execute(post, new StringCallback() {
```java
AsyncHttpServer server = new AsyncHttpServer();
+
+List<WebSocket> _sockets = new ArrayList<WebSocket>();
+
server.get("/", new HttpServerRequestCallback() {
@Override
public void onRequest(AsyncHttpServerRequest request, AsyncHttpServerResponse response) {
response.send("Hello!!!");
}
});
+
+server.websocket("/live", new WebSocketRequestCallback() {
+ @Override
+ public void onConnected(final WebSocket webSocket, RequestHeaders headers) {
+ _sockets.add(webSocket);
+
+ //Use this to clean up any references to your websocket
+ websocket.setClosedCallback(new CompletedCallback() {
+ @Override
+ public void onCompleted(Exception ex) {
+ try {
+ if (ex != null)
+ Log.e("WebSocket", "Error");
+ } finally {
+ _sockets.remove(webSocket);
+ }
+ }
+ });
+
+ webSocket.setStringCallback(new StringCallback() {
+ @Override
+ public void onStringAvailable(String s) {
+ if ("Hello Server".equals(s))
+ webSocket.send("Welcome Client!");
+ }
+ });
+
+ }
+});
// listen on port 5000
server.listen(5000);
// browsing http://localhost:5000 will return Hello!!!
-```
+
+//..Sometime later, broadcast!
+for (WebSocket socket : _sockets)
+ socket.send("Fireball!");
### Futures