@Deprecated public class GrpcBufferingInterceptor extends Object implements io.grpc.ClientInterceptor
As an additional message is requested by default each time a message is received, setting an initial request amount will allow that number of messages to be "in transit" before the server stops sending more.
Constructor and Description |
---|
GrpcBufferingInterceptor(int additionalBuffer)
Deprecated.
Initialize the interceptor to ask for
additionalBuffer amount of messages from the server. |
Modifier and Type | Method and Description |
---|---|
<ReqT,RespT> |
interceptCall(io.grpc.MethodDescriptor<ReqT,RespT> method,
io.grpc.CallOptions callOptions,
io.grpc.Channel next)
Deprecated.
|
public GrpcBufferingInterceptor(int additionalBuffer)
additionalBuffer
amount of messages from the server.additionalBuffer
- The number of messages the server may send before waiting for permits to be renewedCopyright © 2010–2023. All rights reserved.