Skip to content

Commit c3d75c3

Browse files
remove onmessage, onconnect, and ondisconnect from websocket
1 parent f56f12c commit c3d75c3

File tree

1 file changed

+3
-37
lines changed

1 file changed

+3
-37
lines changed

src/Nitric.Sdk/Resource/WebsocketResource.cs

Lines changed: 3 additions & 37 deletions
Original file line numberDiff line numberDiff line change
@@ -86,49 +86,15 @@ public void On(Service.WebsocketEventType eventType, params Middleware<Websocket
8686
}
8787

8888
/// <summary>
89-
/// Registers a handler to be called whenever a connection event is published to this websocket.
89+
/// Registers a handler to be called whenever an event is published to this websocket.
9090
/// </summary>
9191
/// <param name="handler">The handler to call to process websocket events</param>
92-
public void OnConnect(Func<WebsocketContext, Task<WebsocketContext>> handler)
92+
public void On(Service.WebsocketEventType eventType, Func<WebsocketContext, Task<WebsocketContext>> handler)
9393
{
9494
var registrationRequest = new RegistrationRequest
9595
{
9696
SocketName = Name,
97-
EventType = Service.WebsocketEventType.Connected.ToGrpc()
98-
};
99-
100-
var websocketWorker = new WebsocketWorker(registrationRequest, handler);
101-
102-
Nitric.RegisterWorker(websocketWorker);
103-
}
104-
105-
/// <summary>
106-
/// Registers a handler to be called whenever a disconnection event is published to this websocket.
107-
/// </summary>
108-
/// <param name="handler">The handler to call to process websocket events</param>
109-
public void OnDisconnect(Func<WebsocketContext, Task<WebsocketContext>> handler)
110-
{
111-
var registrationRequest = new RegistrationRequest
112-
{
113-
SocketName = Name,
114-
EventType = Service.WebsocketEventType.Disconnected.ToGrpc()
115-
};
116-
117-
var websocketWorker = new WebsocketWorker(registrationRequest, handler);
118-
119-
Nitric.RegisterWorker(websocketWorker);
120-
}
121-
122-
/// <summary>
123-
/// Registers a handler to be called whenever a message event is published to this websocket.
124-
/// </summary>
125-
/// <param name="handler">The handler to call to process websocket events</param>
126-
public void OnMessage(Func<WebsocketContext, Task<WebsocketContext>> handler)
127-
{
128-
var registrationRequest = new RegistrationRequest
129-
{
130-
SocketName = Name,
131-
EventType = Service.WebsocketEventType.Message.ToGrpc()
97+
EventType = eventType.ToGrpc()
13298
};
13399

134100
var websocketWorker = new WebsocketWorker(registrationRequest, handler);

0 commit comments

Comments
 (0)