@Test public void testPipelining() throws Exception { Eventloop eventloop = Eventloop.create().withFatalErrorHandler(rethrowOnAnyError()).withCurrentThread(); int port = getFreePort(); doTestPipelining(eventloop, delayedHttpServer(eventloop, port), port); }
public static AsyncHttpServer create(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet) { return new AsyncHttpServer(eventloop, servlet); }
AsyncHttpServer extends AbstractServer<AsyncHttpServer> { public static AsyncHttpServer create(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet) { return new AsyncHttpServer(eventloop, servlet); } }
AsyncHttpServer extends AbstractServer<AsyncHttpServer> { public static AsyncHttpServer create(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet) { return new AsyncHttpServer(eventloop, servlet); } private  AsyncHttpServer(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet); }
AsyncHttpServer extends AbstractServer<AsyncHttpServer> { public static AsyncHttpServer create(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet) { return new AsyncHttpServer(eventloop, servlet); } private  AsyncHttpServer(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet); static AsyncHttpServer create(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet); AsyncHttpServer withKeepAliveTimeout(@NotNull Duration keepAliveTime); AsyncHttpServer withMaxKeepAliveRequests(int maxKeepAliveRequests); AsyncHttpServer withNoKeepAlive(); AsyncHttpServer withReadWriteTimeout(@NotNull Duration readWriteTimeout); AsyncHttpServer withReadWriteTimeout(@NotNull Duration readWriteTimeout, @NotNull Duration readWriteTimeoutShutdown); AsyncHttpServer withServeTimeoutShutdown(@NotNull Duration serveTimeoutShutdown); AsyncHttpServer withMaxBodySize(MemSize maxBodySize); AsyncHttpServer withMaxBodySize(int maxBodySize); AsyncHttpServer withHttpErrorFormatter(@NotNull HttpExceptionFormatter httpExceptionFormatter); AsyncHttpServer withInspector(Inspector inspector); Duration getKeepAliveTimeout(); Duration getReadWriteTimeout(); Promise<Void> getCloseNotification(); List<String> getHttpAddresses(); @JmxAttribute(description = "current number of connections", reducer = JmxReducerSum.class) int getConnectionsCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsNewCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsReadWriteCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsServingCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsKeepAliveCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsKeepAliveExpired(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsReadWriteExpired(); @JmxAttribute(name = "") @Nullable JmxInspector getStats(); @Override String toString(); }
AsyncHttpServer extends AbstractServer<AsyncHttpServer> { public static AsyncHttpServer create(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet) { return new AsyncHttpServer(eventloop, servlet); } private  AsyncHttpServer(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet); static AsyncHttpServer create(@NotNull Eventloop eventloop, @NotNull AsyncServlet servlet); AsyncHttpServer withKeepAliveTimeout(@NotNull Duration keepAliveTime); AsyncHttpServer withMaxKeepAliveRequests(int maxKeepAliveRequests); AsyncHttpServer withNoKeepAlive(); AsyncHttpServer withReadWriteTimeout(@NotNull Duration readWriteTimeout); AsyncHttpServer withReadWriteTimeout(@NotNull Duration readWriteTimeout, @NotNull Duration readWriteTimeoutShutdown); AsyncHttpServer withServeTimeoutShutdown(@NotNull Duration serveTimeoutShutdown); AsyncHttpServer withMaxBodySize(MemSize maxBodySize); AsyncHttpServer withMaxBodySize(int maxBodySize); AsyncHttpServer withHttpErrorFormatter(@NotNull HttpExceptionFormatter httpExceptionFormatter); AsyncHttpServer withInspector(Inspector inspector); Duration getKeepAliveTimeout(); Duration getReadWriteTimeout(); Promise<Void> getCloseNotification(); List<String> getHttpAddresses(); @JmxAttribute(description = "current number of connections", reducer = JmxReducerSum.class) int getConnectionsCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsNewCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsReadWriteCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsServingCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsKeepAliveCount(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsKeepAliveExpired(); @JmxAttribute(reducer = JmxReducerSum.class) int getConnectionsReadWriteExpired(); @JmxAttribute(name = "") @Nullable JmxInspector getStats(); @Override String toString(); static final Duration READ_WRITE_TIMEOUT; static final Duration READ_WRITE_TIMEOUT_SHUTDOWN; static final Duration SERVE_TIMEOUT_SHUTDOWN; static final Duration KEEP_ALIVE_TIMEOUT; static final MemSize MAX_BODY_SIZE; static final int MAX_KEEP_ALIVE_REQUESTS; }