equal
deleted
inserted
replaced
33 import org.testng.annotations.Test; |
33 import org.testng.annotations.Test; |
34 |
34 |
35 import java.io.IOException; |
35 import java.io.IOException; |
36 import java.net.http.WebSocket; |
36 import java.net.http.WebSocket; |
37 |
37 |
38 import static java.net.http.HttpClient.newHttpClient; |
38 import static java.net.http.HttpClient.Builder.NO_PROXY; |
|
39 import static java.net.http.HttpClient.newBuilder; |
39 import static java.net.http.WebSocket.NORMAL_CLOSURE; |
40 import static java.net.http.WebSocket.NORMAL_CLOSURE; |
40 import static org.testng.Assert.assertEquals; |
41 import static org.testng.Assert.assertEquals; |
41 import static org.testng.Assert.assertThrows; |
42 import static org.testng.Assert.assertThrows; |
42 import static org.testng.Assert.assertTrue; |
43 import static org.testng.Assert.assertTrue; |
43 |
44 |
56 |
57 |
57 @Test |
58 @Test |
58 public void sendMethodsThrowNPE() throws IOException { |
59 public void sendMethodsThrowNPE() throws IOException { |
59 server = new DummyWebSocketServer(); |
60 server = new DummyWebSocketServer(); |
60 server.open(); |
61 server.open(); |
61 webSocket = newHttpClient().newWebSocketBuilder() |
62 webSocket = newBuilder().proxy(NO_PROXY).build().newWebSocketBuilder() |
62 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
63 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
63 .join(); |
64 .join(); |
64 |
65 |
65 assertThrows(NPE, () -> webSocket.sendText(null, false)); |
66 assertThrows(NPE, () -> webSocket.sendText(null, false)); |
66 assertThrows(NPE, () -> webSocket.sendText(null, true)); |
67 assertThrows(NPE, () -> webSocket.sendText(null, true)); |
87 |
88 |
88 @Test |
89 @Test |
89 public void sendCloseCompleted() throws IOException { |
90 public void sendCloseCompleted() throws IOException { |
90 server = new DummyWebSocketServer(); |
91 server = new DummyWebSocketServer(); |
91 server.open(); |
92 server.open(); |
92 webSocket = newHttpClient().newWebSocketBuilder() |
93 webSocket = newBuilder().proxy(NO_PROXY).build().newWebSocketBuilder() |
93 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
94 .buildAsync(server.getURI(), new WebSocket.Listener() { }) |
94 .join(); |
95 .join(); |
95 webSocket.sendClose(NORMAL_CLOSURE, "").join(); |
96 webSocket.sendClose(NORMAL_CLOSURE, "").join(); |
96 assertTrue(webSocket.isOutputClosed()); |
97 assertTrue(webSocket.isOutputClosed()); |
97 assertEquals(webSocket.getSubprotocol(), ""); |
98 assertEquals(webSocket.getSubprotocol(), ""); |