Skip to content

Commit

Permalink
less visibility
Browse files Browse the repository at this point in the history
  • Loading branch information
StefanBratanov committed Jan 9, 2025
1 parent 1796ec8 commit 3e3d8b2
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -250,12 +250,11 @@ private static class ThrottlingRpcHandler<
private final ThrottlingTaskQueue requestsQueue =
ThrottlingTaskQueue.create(NetworkConstants.MAX_CONCURRENT_REQUESTS);

public ThrottlingRpcHandler(
final RpcHandler<TOutgoingHandler, TRequest, TRespHandler> delegate) {
ThrottlingRpcHandler(final RpcHandler<TOutgoingHandler, TRequest, TRespHandler> delegate) {
this.delegate = delegate;
}

public SafeFuture<RpcStreamController<TOutgoingHandler>> sendRequest(
SafeFuture<RpcStreamController<TOutgoingHandler>> sendRequest(
final Connection connection, final TRequest request, final TRespHandler responseHandler) {
return requestsQueue.queueTask(
() -> delegate.sendRequest(connection, request, responseHandler));
Expand Down

0 comments on commit 3e3d8b2

Please sign in to comment.