Update README.md

paulpdaniels · paulpdaniels · commit db72f5050ddf · 2014-04-18T12:18:48.000-07:00
Added sample code from koush#136
diff --git 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
 
