Skip to content

Commit ece29b2

Browse files
committed
fixes
Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
1 parent d7d9a89 commit ece29b2

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/WebsocketDuplexConnection.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,11 @@ public WebsocketDuplexConnection(Connection connection) {
6060
// if (!isDisposed()) dispose();
6161
// });
6262

63-
connection.outbound().sendObject(sender.map(BinaryWebSocketFrame::new).log("queue " + this)).then().subscribe();
63+
connection
64+
.outbound()
65+
.sendObject(sender.map(BinaryWebSocketFrame::new).log("queue " + this))
66+
.then()
67+
.subscribe();
6468
}
6569

6670
@Override

0 commit comments

Comments
 (0)