h4ckx0r/socket.io-client-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bump engine.io-client

Browse Source
This commit is contained in:
Naoyuki Kanezawa
2015-08-09 06:35:56 +09:00
parent 92dcd143e3
commit 6eeaf6a6e3
2 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@@ -58,7 +58,7 @@
<dependency> <dependency>
<groupId>com.github.nkzawa</groupId> <groupId>com.github.nkzawa</groupId>
<artifactId>engine.io-client</artifactId> <artifactId>engine.io-client</artifactId>
<version>0.5.1</version> <version>0.6.0-SNAPSHOT</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.json</groupId> <groupId>org.json</groupId>

22
src/test/java/com/github/nkzawa/socketio/client/ServerConnectionTest.java
View File

@@ -10,6 +10,8 @@ import org.junit.runner.RunWith;
import org.junit.runners.JUnit4; import org.junit.runners.JUnit4;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.Arrays;
import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.BlockingQueue; import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.LinkedBlockingQueue;
@@ -282,16 +284,16 @@ public class ServerConnectionTest extends Connection {
@Override @Override
public void call(Object... args) { public void call(Object... args) {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
Map<String, String> headers = (Map<String, String>)args[0]; Map<String, List<String>> headers = (Map<String, List<String>>)args[0];
headers.put("X-SocketIO", "hi"); headers.put("X-SocketIO", Arrays.asList("hi"));
} }
}).on(Transport.EVENT_RESPONSE_HEADERS, new Emitter.Listener() { }).on(Transport.EVENT_RESPONSE_HEADERS, new Emitter.Listener() {
@Override @Override
public void call(Object... args) { public void call(Object... args) {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
Map<String, String> headers = (Map<String, String>)args[0]; Map<String, List<String>> headers = (Map<String, List<String>>)args[0];
String value = headers.get("X-SocketIO"); List<String> value = headers.get("X-SocketIO");
values.offer(value != null ? value : ""); values.offer(value != null ? value.get(0) : "");
} }
}); });
} }
@@ -317,16 +319,16 @@ public class ServerConnectionTest extends Connection {
@Override @Override
public void call(Object... args) { public void call(Object... args) {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
Map<String, String> headers = (Map<String, String>)args[0]; Map<String, List<String>> headers = (Map<String, List<String>>)args[0];
headers.put("X-SocketIO", "hi"); headers.put("X-SocketIO", Arrays.asList("hi"));
} }
}).on(Transport.EVENT_RESPONSE_HEADERS, new Emitter.Listener() { }).on(Transport.EVENT_RESPONSE_HEADERS, new Emitter.Listener() {
@Override @Override
public void call(Object... args) { public void call(Object... args) {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
Map<String, String> headers = (Map<String, String>)args[0]; Map<String, List<String>> headers = (Map<String, List<String>>)args[0];
String value = headers.get("X-SocketIO"); List<String> value = headers.get("X-SocketIO");
values.offer(value != null ? value : ""); values.offer(value != null ? value.get(0) : "");
} }
}); });
} }