Skip to content

Commit

Permalink
minor fix
Browse files Browse the repository at this point in the history
  • Loading branch information
idelpivnitskiy committed Sep 29, 2023
1 parent c746fb4 commit 70be0c1
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,11 +45,6 @@
final class AlpnChannelSingle extends ChannelInitSingle<String> {
private final Consumer<ChannelHandlerContext> onHandlerAdded;

AlpnChannelSingle(final Channel channel,
final ChannelInitializer channelInitializer) {
this(channel, channelInitializer, __ -> { });
}

AlpnChannelSingle(final Channel channel,
final ChannelInitializer channelInitializer,
final Consumer<ChannelHandlerContext> onHandlerAdded) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,8 +69,8 @@ Single<FilterableStreamingHttpConnection> newFilterableConnection(
private Single<FilterableStreamingHttpConnection> createConnection(
final Channel channel, final ConnectionObserver connectionObserver,
final ReadOnlyTcpClientConfig tcpConfig) {
return new AlpnChannelSingle(channel,
new TcpClientChannelInitializer(tcpConfig, connectionObserver)).flatMap(protocol -> {
return new AlpnChannelSingle(channel, new TcpClientChannelInitializer(tcpConfig, connectionObserver),
ctx -> { /* SslHandler will automatically start handshake on channelActive */ }).flatMap(protocol -> {
switch (protocol) {
case HTTP_1_1:
final H1ProtocolConfig h1Config = config.h1Config();
Expand Down

0 comments on commit 70be0c1

Please sign in to comment.