--
You received this message because you are subscribed to the Google Groups "vert.x" group.
To unsubscribe from this group and stop receiving emails from it, send an email to vertx+un...@googlegroups.com.
Visit this group at https://groups.google.com/group/vertx.
To view this discussion on the web, visit https://groups.google.com/d/msgid/vertx/b964c679-52cd-4383-a4f5-cc678cf0bdc8%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
To view this discussion on the web, visit https://groups.google.com/d/msgid/vertx/70f7da0a-9b83-4a34-9dc9-2eaccf83d255%40googlegroups.com.
private Handler<NetSocket> onConnect() {
return socket -> {
socket.pause();
String connectionId = socket.writeHandlerID();
execute(connectionId).subscribe(() -> {
socket.handler(onStanzaReceiveHandler(connectionId))
.closeHandler(onCloseHandler(connectionId));
socket.resume();
});
};
}
Do you have a reproducer for this? It would it easier for me to understand.