equal
deleted
inserted
replaced
41 import java.nio.ByteBuffer; |
41 import java.nio.ByteBuffer; |
42 import java.nio.charset.StandardCharsets; |
42 import java.nio.charset.StandardCharsets; |
43 import java.util.ArrayList; |
43 import java.util.ArrayList; |
44 import java.util.List; |
44 import java.util.List; |
45 import java.util.Random; |
45 import java.util.Random; |
46 |
46 import static java.net.http.HttpClient.Builder.NO_PROXY; |
47 import static java.net.http.HttpClient.newHttpClient; |
47 import static java.net.http.HttpClient.newBuilder; |
48 import static org.testng.Assert.assertEquals; |
48 import static org.testng.Assert.assertEquals; |
49 import static org.testng.Assert.assertTrue; |
49 import static org.testng.Assert.assertTrue; |
50 |
50 |
51 |
51 |
52 /* |
52 /* |
69 |
69 |
70 @Test(dataProvider = "binary") |
70 @Test(dataProvider = "binary") |
71 public void binary(ByteBuffer expected) throws IOException, InterruptedException { |
71 public void binary(ByteBuffer expected) throws IOException, InterruptedException { |
72 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
72 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
73 server.open(); |
73 server.open(); |
74 WebSocket ws = newHttpClient() |
74 WebSocket ws = newBuilder().proxy(NO_PROXY).build() |
75 .newWebSocketBuilder() |
75 .newWebSocketBuilder() |
76 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
76 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
77 .join(); |
77 .join(); |
78 ws.sendBinary(expected.duplicate(), true).join(); |
78 ws.sendBinary(expected.duplicate(), true).join(); |
79 ws.abort(); |
79 ws.abort(); |
164 |
164 |
165 @Test(dataProvider = "pingPong") |
165 @Test(dataProvider = "pingPong") |
166 public void ping(ByteBuffer expected) throws Exception { |
166 public void ping(ByteBuffer expected) throws Exception { |
167 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
167 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
168 server.open(); |
168 server.open(); |
169 WebSocket ws = newHttpClient() |
169 WebSocket ws = newBuilder().proxy(NO_PROXY).build() |
170 .newWebSocketBuilder() |
170 .newWebSocketBuilder() |
171 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
171 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
172 .join(); |
172 .join(); |
173 ws.sendPing(expected.duplicate()).join(); |
173 ws.sendPing(expected.duplicate()).join(); |
174 ws.abort(); |
174 ws.abort(); |
186 |
186 |
187 @Test(dataProvider = "pingPong") |
187 @Test(dataProvider = "pingPong") |
188 public void pong(ByteBuffer expected) throws Exception { |
188 public void pong(ByteBuffer expected) throws Exception { |
189 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
189 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
190 server.open(); |
190 server.open(); |
191 WebSocket ws = newHttpClient() |
191 WebSocket ws = newBuilder().proxy(NO_PROXY).build() |
192 .newWebSocketBuilder() |
192 .newWebSocketBuilder() |
193 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
193 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
194 .join(); |
194 .join(); |
195 ws.sendPong(expected.duplicate()).join(); |
195 ws.sendPong(expected.duplicate()).join(); |
196 ws.abort(); |
196 ws.abort(); |
208 |
208 |
209 @Test(dataProvider = "close") |
209 @Test(dataProvider = "close") |
210 public void close(int statusCode, String reason) throws Exception { |
210 public void close(int statusCode, String reason) throws Exception { |
211 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
211 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
212 server.open(); |
212 server.open(); |
213 WebSocket ws = newHttpClient() |
213 WebSocket ws = newBuilder().proxy(NO_PROXY).build() |
214 .newWebSocketBuilder() |
214 .newWebSocketBuilder() |
215 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
215 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
216 .join(); |
216 .join(); |
217 ws.sendClose(statusCode, reason).join(); |
217 ws.sendClose(statusCode, reason).join(); |
218 ws.abort(); |
218 ws.abort(); |
231 |
231 |
232 @Test(dataProvider = "text") |
232 @Test(dataProvider = "text") |
233 public void text(String expected) throws Exception { |
233 public void text(String expected) throws Exception { |
234 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
234 try (DummyWebSocketServer server = new DummyWebSocketServer()) { |
235 server.open(); |
235 server.open(); |
236 WebSocket ws = newHttpClient() |
236 WebSocket ws = newBuilder().proxy(NO_PROXY).build() |
237 .newWebSocketBuilder() |
237 .newWebSocketBuilder() |
238 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
238 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
239 .join(); |
239 .join(); |
240 ws.sendText(expected, true).join(); |
240 ws.sendText(expected, true).join(); |
241 ws.abort(); |
241 ws.abort(); |