本文整理了Java中io.vertx.core.http.HttpConnection.remoteSettings()方法的一些代码示例，展示了HttpConnection.remoteSettings()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HttpConnection.remoteSettings()方法的具体详情如下：
包路径：io.vertx.core.http.HttpConnection
类名称：HttpConnection
方法名：remoteSettings

HttpConnection.remoteSettings介绍

暂无

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testInitialMaxConcurrentStreamZero() throws Exception {
 server.close();
 server = vertx.createHttpServer(createBaseServerOptions().setInitialSettings(new Http2Settings().setMaxConcurrentStreams(0)));
 server.requestHandler(req -> {
  req.response().end();
 });
 server.connectionHandler(conn -> {
  vertx.setTimer(500, id -> {
   conn.updateSettings(new Http2Settings().setMaxConcurrentStreams(10));
  });
 });
 startServer();
 client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, resp -> {
  testComplete();
 }).connectionHandler(conn -> {
  assertEquals(10, conn.remoteSettings().getMaxConcurrentStreams());
 }).setTimeout(10000).exceptionHandler(this::fail).end();
 await();
}

代码示例来源：origin: eclipse-vertx/vert.x

});
}).connectionHandler(conn -> {
 io.vertx.core.http.Http2Settings initialRemoteSettings = conn.remoteSettings();
 assertEquals(initialSettings.isPushEnabled(), initialRemoteSettings.isPushEnabled());
 assertEquals(initialSettings.getMaxHeaderListSize(), initialRemoteSettings.getMaxHeaderListSize());

代码示例来源：origin: io.vertx/vertx-core

});
}).connectionHandler(conn -> {
 io.vertx.core.http.Http2Settings initialRemoteSettings = conn.remoteSettings();
 assertEquals(initialSettings.isPushEnabled(), initialRemoteSettings.isPushEnabled());
 assertEquals(initialSettings.getMaxHeaderListSize(), initialRemoteSettings.getMaxHeaderListSize());

代码示例来源：origin: eclipse-vertx/vert.x

client.get(DEFAULT_HTTPS_PORT, DEFAULT_HTTPS_HOST, "/somepath", resp -> {
}).connectionHandler(conn -> {
 assertEquals(max == null ? 0xFFFFFFFFL : max, conn.remoteSettings().getMaxConcurrentStreams());
 latch.countDown();
}).exceptionHandler(err -> {

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * @return the current remote endpoint settings for this connection - this is not implemented for HTTP/1.x
 */
public Http2Settings remoteSettings() { 
 Http2Settings ret = delegate.remoteSettings();
 return ret;
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * @return the current remote endpoint settings for this connection - this is not implemented for HTTP/1.x
 */
public Http2Settings remoteSettings() { 
 Http2Settings ret = delegate.remoteSettings();
 return ret;
}

代码示例来源：origin: io.vertx/vertx-lang-groovy

public static java.util.Map<String, Object> remoteSettings(io.vertx.core.http.HttpConnection j_receiver) {
 return j_receiver.remoteSettings() != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(j_receiver.remoteSettings().toJson()) : null;
}
public static io.vertx.core.http.HttpConnection remoteSettingsHandler(io.vertx.core.http.HttpConnection j_receiver, io.vertx.core.Handler<java.util.Map<String, Object>> handler) {

代码示例来源：origin: io.vertx/vertx-core

client.get(DEFAULT_HTTPS_PORT, DEFAULT_HTTPS_HOST, "/somepath", resp -> {
}).connectionHandler(conn -> {
 assertEquals(max == null ? 0xFFFFFFFFL : max, conn.remoteSettings().getMaxConcurrentStreams());
 latch.countDown();
}).exceptionHandler(err -> {

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testInitialMaxConcurrentStreamZero() throws Exception {
 server.close();
 server = vertx.createHttpServer(createBaseServerOptions().setInitialSettings(new Http2Settings().setMaxConcurrentStreams(0)));
 server.requestHandler(req -> {
  req.response().end();
 });
 server.connectionHandler(conn -> {
  vertx.setTimer(500, id -> {
   conn.updateSettings(new Http2Settings().setMaxConcurrentStreams(10));
  });
 });
 startServer();
 client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, resp -> {
  testComplete();
 }).connectionHandler(conn -> {
  assertEquals(10, conn.remoteSettings().getMaxConcurrentStreams());
 }).setTimeout(10000).exceptionHandler(this::fail).end();
 await();
}