}
void setHandlers(NetSocket sock) {
Handler<Message<Buffer>> resumeHandler = m -> sock.resume();
MessageConsumer reg = vertx.eventBus().<Buffer>consumer("client_resume").handler(resumeHandler);
sock.closeHandler(v -> reg.unregister());
}
void drainingServer(Handler<AsyncResult<NetServer>> listenHandler) {
server.connectHandler(sock -> {
assertFalse(sock.writeQueueFull());