add a test for room

src/test/java/com/github/nkzawa/socketio/client/ServerConnectionTest.java

@@ -230,7 +230,6 @@ public class ServerConnectionTest extends Connection {
             @Override
             public void call(Object... objects) {
                 assertThat(objects.length, is(1));
-                assertThat(objects[0], is(instanceOf(String.class)));
                 assertThat((String)objects[0], is("hi"));
                 socket.disconnect();
                 socket2.disconnect();
@@ -240,4 +239,27 @@ public class ServerConnectionTest extends Connection {
         socket.connect();
         semaphore.acquire();
     }
+
+    @Test(timeout = TIMEOUT)
+    public void room() throws URISyntaxException, InterruptedException {
+        final Semaphore semaphore = new Semaphore(0);
+
+        socket = client();
+        socket.on(Socket.EVENT_CONNECT, new Emitter.Listener() {
+            @Override
+            public void call(Object... objects) {
+                socket.emit("room", "hi");
+            }
+        }).on("roomBack", new Emitter.Listener() {
+            @Override
+            public void call(Object... objects) {
+                assertThat(objects.length, is(1));
+                assertThat((String)objects[0], is("hi"));
+                socket.disconnect();
+                semaphore.release();
+            }
+        });
+        socket.connect();
+        semaphore.acquire();
+    }
 }

src/test/resources/server.js

@@ -50,6 +50,11 @@ io.of(nsp).on('connection', function(socket) {
     socket.broadcast.emit.apply(socket, ['broadcastBack'].concat(args));
   });
 
+  socket.on('room', function() {
+    var args = slice.call(arguments);
+    io.to(socket.id).emit.apply(socket, ['roomBack'].concat(args));
+  });
+
   socket.on('disconnect', function() {
     console.log('disconnect');
   });