Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6189#discussion_r197069640 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java --- @@ -212,6 +271,86 @@ public void shutdown(Time timeout) { executor); } + private interface RequestProcessor<T> { + T createRequest(HttpRequest request, ByteBuf jsonPayload) throws IOException; + + void writeRequest(T body, Channel channel) throws IOException; --- End diff -- Change this method to only take a `Channel`.
---