|
|
|
@ -68,6 +68,7 @@ public class JettyWebSocketSession extends AbstractWebSocketSession<Session> { |
|
|
|
@Nullable |
|
|
|
@Nullable |
|
|
|
private final Sinks.Empty<Void> handlerCompletionSink; |
|
|
|
private final Sinks.Empty<Void> handlerCompletionSink; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public JettyWebSocketSession(Session session, HandshakeInfo info, DataBufferFactory factory) { |
|
|
|
public JettyWebSocketSession(Session session, HandshakeInfo info, DataBufferFactory factory) { |
|
|
|
this(session, info, factory, null); |
|
|
|
this(session, info, factory, null); |
|
|
|
} |
|
|
|
} |
|
|
|
@ -107,6 +108,7 @@ public class JettyWebSocketSession extends AbstractWebSocketSession<Session> { |
|
|
|
}); |
|
|
|
}); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void handleMessage(WebSocketMessage message) { |
|
|
|
void handleMessage(WebSocketMessage message) { |
|
|
|
Assert.state(this.sink != null, "No sink available"); |
|
|
|
Assert.state(this.sink != null, "No sink available"); |
|
|
|
this.sink.next(message); |
|
|
|
this.sink.next(message); |
|
|
|
@ -189,7 +191,6 @@ public class JettyWebSocketSession extends AbstractWebSocketSession<Session> { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
protected Mono<Void> sendMessage(WebSocketMessage message) { |
|
|
|
protected Mono<Void> sendMessage(WebSocketMessage message) { |
|
|
|
|
|
|
|
|
|
|
|
Callback.Completable completable = new Callback.Completable(); |
|
|
|
Callback.Completable completable = new Callback.Completable(); |
|
|
|
DataBuffer dataBuffer = message.getPayload(); |
|
|
|
DataBuffer dataBuffer = message.getPayload(); |
|
|
|
Session session = getDelegate(); |
|
|
|
Session session = getDelegate(); |
|
|
|
@ -245,4 +246,5 @@ public class JettyWebSocketSession extends AbstractWebSocketSession<Session> { |
|
|
|
} |
|
|
|
} |
|
|
|
return Mono.fromFuture(completable); |
|
|
|
return Mono.fromFuture(completable); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|