2323import javax .net .ssl .TrustManager ;
2424import javax .net .ssl .X509TrustManager ;
2525
26- import org .jetbrains .annotations .NotNull ;
27- import org .jetbrains .annotations .Nullable ;
28-
2926import edu .umd .cs .findbugs .annotations .NonNull ;
27+ import edu .umd .cs .findbugs .annotations .Nullable ;
3028import io .jooby .Server ;
3129import io .jooby .ServerSentMessage ;
3230import io .jooby .SneakyThrows ;
@@ -54,26 +52,26 @@ public SyncWebSocketListener(String testName) {
5452 }
5553
5654 @ Override
57- public void onOpen (@ NotNull WebSocket webSocket , @ NotNull Response response ) {
55+ public void onOpen (@ NonNull WebSocket webSocket , @ NonNull Response response ) {
5856 opened .countDown ();
5957 }
6058
6159 @ Override
62- public void onClosed (@ NotNull WebSocket webSocket , int code , @ NotNull String reason ) {
60+ public void onClosed (@ NonNull WebSocket webSocket , int code , @ NonNull String reason ) {
6361 closed .set (true );
6462 }
6563
6664 @ Override
6765 public void onFailure (
68- @ NotNull WebSocket webSocket , @ NotNull Throwable e , @ Nullable Response response ) {
66+ @ NonNull WebSocket webSocket , @ NonNull Throwable e , @ Nullable Response response ) {
6967 if (!Server .connectionLost (e )) {
7068 System .err .println ("Unexpected web socket error: " + testName );
7169 e .printStackTrace ();
7270 }
7371 }
7472
7573 @ Override
76- public void onMessage (@ NotNull WebSocket webSocket , @ NotNull String text ) {
74+ public void onMessage (@ NonNull WebSocket webSocket , @ NonNull String text ) {
7775 messages .offer (text );
7876 }
7977
@@ -91,7 +89,7 @@ public String lastMessage() {
9189 }
9290
9391 @ Override
94- public void onClosing (@ NotNull WebSocket webSocket , int code , @ NotNull String reason ) {
92+ public void onClosing (@ NonNull WebSocket webSocket , int code , @ NonNull String reason ) {
9593 super .onClosing (webSocket , code , reason );
9694 }
9795 }
@@ -261,31 +259,31 @@ public ServerSentMessageIterator sse(String path) {
261259 req .build (),
262260 new EventSourceListener () {
263261 @ Override
264- public void onClosed (@ NotNull EventSource eventSource ) {
262+ public void onClosed (@ NonNull EventSource eventSource ) {
265263 eventSource .cancel ();
266264 }
267265
268266 @ Override
269267 public void onEvent (
270- @ NotNull EventSource eventSource ,
268+ @ NonNull EventSource eventSource ,
271269 @ Nullable String id ,
272270 @ Nullable String type ,
273- @ NotNull String data ) {
271+ @ NonNull String data ) {
274272 // retry is not part of public API
275273 ServerSentMessage message = new ServerSentMessage (data ).setId (id ).setEvent (type );
276274 messages .offer (message );
277275 }
278276
279277 @ Override
280278 public void onFailure (
281- @ NotNull EventSource eventSource ,
279+ @ NonNull EventSource eventSource ,
282280 @ Nullable Throwable t ,
283281 @ Nullable Response response ) {
284282 super .onFailure (eventSource , t , response );
285283 }
286284
287285 @ Override
288- public void onOpen (@ NotNull EventSource eventSource , @ NotNull Response response ) {
286+ public void onOpen (@ NonNull EventSource eventSource , @ NonNull Response response ) {
289287 super .onOpen (eventSource , response );
290288 }
291289 });
0 commit comments