Skip to content

Commit 93e971e

Browse files
committed
Rename WebSocketListener to WebSocketConfigurer
1 parent 4a191c6 commit 93e971e

File tree

4 files changed

+19
-19
lines changed

4 files changed

+19
-19
lines changed

jooby/src/main/java/io/jooby/WebSocket.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55

66
public interface WebSocket {
77
interface Handler {
8-
void init(Context ctx, WebSocketListener initializer);
8+
void init(Context ctx, WebSocketConfigurer configurer);
99
}
1010

1111
interface OnConnect {
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package io.jooby;
2+
3+
public interface WebSocketConfigurer {
4+
5+
WebSocketConfigurer onConnect(WebSocket.OnConnect callback);
6+
7+
WebSocketConfigurer onMessage(WebSocket.OnMessage callback);
8+
9+
WebSocketConfigurer onError(WebSocket.OnError callback);
10+
11+
WebSocketConfigurer onClose(WebSocket.OnClose callback);
12+
}

jooby/src/main/java/io/jooby/WebSocketListener.java

Lines changed: 0 additions & 12 deletions
This file was deleted.

modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyWebSocket.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import io.jooby.SneakyThrows;
77
import io.jooby.WebSocket;
88
import io.jooby.WebSocketCloseStatus;
9-
import io.jooby.WebSocketListener;
9+
import io.jooby.WebSocketConfigurer;
1010
import io.jooby.WebSocketMessage;
1111
import io.netty.buffer.ByteBuf;
1212
import io.netty.buffer.Unpooled;
@@ -23,7 +23,7 @@
2323
import java.util.concurrent.ConcurrentMap;
2424
import java.util.concurrent.CopyOnWriteArrayList;
2525

26-
public class NettyWebSocket implements WebSocketListener, WebSocket {
26+
public class NettyWebSocket implements WebSocketConfigurer, WebSocket {
2727
/** All connected websocket. */
2828
private static final ConcurrentMap<String, List<WebSocket>> all = new ConcurrentHashMap<>();
2929

@@ -92,22 +92,22 @@ public boolean isOpen() {
9292
return netty.ctx.channel().isOpen();
9393
}
9494

95-
@Override public WebSocketListener onConnect(WebSocket.OnConnect callback) {
95+
@Override public WebSocketConfigurer onConnect(WebSocket.OnConnect callback) {
9696
connectCallback = callback;
9797
return this;
9898
}
9999

100-
@Override public WebSocketListener onMessage(WebSocket.OnMessage callback) {
100+
@Override public WebSocketConfigurer onMessage(WebSocket.OnMessage callback) {
101101
messageCallback = callback;
102102
return this;
103103
}
104104

105-
@Override public WebSocketListener onClose(WebSocket.OnClose callback) {
105+
@Override public WebSocketConfigurer onClose(WebSocket.OnClose callback) {
106106
onCloseCallback = callback;
107107
return this;
108108
}
109109

110-
@Override public WebSocketListener onError(OnError callback) {
110+
@Override public WebSocketConfigurer onError(OnError callback) {
111111
onErrorCallback = callback;
112112
return this;
113113
}

0 commit comments

Comments
 (0)