Skip to content

Commit

Permalink
Don't use NioSocketChannel
Browse files Browse the repository at this point in the history
  • Loading branch information
vietj committed Sep 20, 2017
1 parent 63724ca commit 1303c1c
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions src/test/java/io/vertx/test/core/Http2Test.java
Expand Up @@ -16,17 +16,14 @@

package io.vertx.test.core;

import io.netty.channel.Channel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.channel.socket.SocketChannel;
import io.vertx.core.Context;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.http.Http2Settings;
import io.vertx.core.http.HttpClientOptions;
import io.vertx.core.http.HttpClientRequest;
import io.vertx.core.http.HttpConnection;
import io.vertx.core.http.HttpServerOptions;
import io.vertx.core.http.HttpServerResponse;
import io.vertx.core.http.HttpVersion;
import io.vertx.core.http.StreamResetException;
import io.vertx.core.http.impl.Http2ServerConnection;
import io.vertx.core.net.OpenSSLEngineOptions;
Expand All @@ -38,7 +35,6 @@
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;

/**
* @author <a href="mailto:julien@julienviet.com">Julien Viet</a>
Expand Down Expand Up @@ -298,7 +294,7 @@ public void testDiscardConnectionWhenChannelBecomesInactive() throws Exception {
server.requestHandler(req -> {
if (count.getAndIncrement() == 0) {
Http2ServerConnection a = (Http2ServerConnection) req.connection();
NioSocketChannel channel = (NioSocketChannel) a.channel();
SocketChannel channel = (SocketChannel) a.channel();
channel.shutdown();
} else {
req.response().end();
Expand Down

0 comments on commit 1303c1c

Please sign in to comment.