io.netty.channel.ChannelPipeline#first ( )源码实例Demo

下面列出了io.netty.channel.ChannelPipeline#first ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： nomulus 文件： SslServerInitializerTest.java

@Test
public void testSuccess_swappedInitializerWithSslHandler() throws Exception {
  SelfSignedCaCertificate ssc = SelfSignedCaCertificate.create(SSL_HOST);
  SslServerInitializer<EmbeddedChannel> sslServerInitializer =
      new SslServerInitializer<>(
          true,
          false,
          sslProvider,
          Suppliers.ofInstance(ssc.key()),
          Suppliers.ofInstance(ImmutableList.of(ssc.cert())));
  EmbeddedChannel channel = new EmbeddedChannel();
  ChannelPipeline pipeline = channel.pipeline();
  pipeline.addLast(sslServerInitializer);
  ChannelHandler firstHandler = pipeline.first();
  assertThat(firstHandler.getClass()).isEqualTo(SslHandler.class);
  SslHandler sslHandler = (SslHandler) firstHandler;
  assertThat(sslHandler.engine().getNeedClientAuth()).isTrue();
  assertThat(channel.isActive()).isTrue();
}

源代码2 项目： nomulus 文件： SslClientInitializerTest.java

@Test
public void testSuccess_swappedInitializerWithSslHandler() throws Exception {
  SslClientInitializer<EmbeddedChannel> sslClientInitializer =
      new SslClientInitializer<>(
          sslProvider, hostProvider, portProvider, ImmutableList.of(), null, null);
  EmbeddedChannel channel = new EmbeddedChannel();
  ChannelPipeline pipeline = channel.pipeline();
  pipeline.addLast(sslClientInitializer);
  ChannelHandler firstHandler = pipeline.first();
  assertThat(firstHandler.getClass()).isEqualTo(SslHandler.class);
  SslHandler sslHandler = (SslHandler) firstHandler;
  assertThat(sslHandler.engine().getPeerHost()).isEqualTo(SSL_HOST);
  assertThat(sslHandler.engine().getPeerPort()).isEqualTo(SSL_PORT);
  assertThat(channel.isActive()).isTrue();
}

源代码3 项目： bazel-buildfarm 文件： HttpBlobStore.java

private boolean isChannelPipelineEmpty(ChannelPipeline pipeline) {
  return (pipeline.first() == null)
      || (useTls
          && "ssl-handler".equals(pipeline.firstContext().name())
          && pipeline.first() == pipeline.last());
}

源代码4 项目： bazel 文件： HttpCacheClient.java

private boolean isChannelPipelineEmpty(ChannelPipeline pipeline) {
  return (pipeline.first() == null)
      || (useTls
          && "ssl-handler".equals(pipeline.firstContext().name())
          && pipeline.first() == pipeline.last());
}

方法所在类

io.netty.channel.ChannelPipeline