Toggle navigation
Home
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.FullHttpRequest to okhttp3.Request
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> External
Mapping:
Add or Remove Method invocation
channelFuture.thenComposeAsync(channel -> { ClientHandler handler=channel.pipeline().get(ClientHandler.class); CompletableFuture<JsonResponse> future=handler.getJsonFuture(); channel.writeAndFlush(httpRequest); return future; } ,executor)
to
channelFuture.thenComposeAsync(channel -> { ClientHandler handler=channel.pipeline().get(ClientHandler.class); CompletableFuture<JsonResponse> future=handler.getJsonFuture(); try { httpRequest.writeTo(channel); } catch ( IOException e) { return FutureUtils.completedExceptionally(new FlinkException("Could not write request.",e)); } return future; } ,executor)