class Eth2OutgoingRequestHandler implements RpcRequestHandler {

  @Override
  public void complete(NodeId nodeId, RpcStream rpcStream) {
    try {
      responseDecoder.complete();
      completeRequest(rpcStream);
    } catch (RpcException e) {
      cancelRequest(rpcStream, e);
    }
  }

  public  Eth2OutgoingRequestHandler(
      final AsyncRunner asyncRunner,
      final AsyncRunner timeoutRunner,
      final Eth2RpcMethod<TRequest, TResponse> method,
      final int maximumResponseChunks);

}