Class StreamingServiceGrpc.StreamingServiceFutureStub (0.44.0)

0.44.0 (latest) 0.42.0 0.40.0 0.39.0 0.37.0 0.35.0 0.33.0 0.32.0 0.31.0 0.30.0 0.29.0 0.27.0 0.25.0 0.24.0 0.21.0 0.20.0 0.19.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

public static final class StreamingServiceGrpc.StreamingServiceFutureStub extends AbstractFutureStub<StreamingServiceGrpc.StreamingServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service StreamingService.

Streaming service for receiving and sending packets.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractFutureStub > StreamingServiceGrpc.StreamingServiceFutureStub

Inherited Members

io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withOnReadyThreshold(int)

io.grpc.stub.AbstractStub.withWaitForReady()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

acquireLease(AcquireLeaseRequest request)

public ListenableFuture<Lease> acquireLease(AcquireLeaseRequest request)

AcquireLease acquires a lease.

Parameter
Name	Description
request	AcquireLeaseRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Lease>

build(Channel channel, CallOptions callOptions)

protected StreamingServiceGrpc.StreamingServiceFutureStub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
channel	io.grpc.Channel
callOptions	io.grpc.CallOptions

Returns
Type	Description
StreamingServiceGrpc.StreamingServiceFutureStub

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

releaseLease(ReleaseLeaseRequest request)

public ListenableFuture<ReleaseLeaseResponse> releaseLease(ReleaseLeaseRequest request)

RleaseLease releases a lease.

Parameter
Name	Description
request	ReleaseLeaseRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<ReleaseLeaseResponse>

renewLease(RenewLeaseRequest request)

public ListenableFuture<Lease> renewLease(RenewLeaseRequest request)

RenewLease renews a lease.

Parameter
Name	Description
request	RenewLeaseRequest

Returns
Type	Description
com.google.common.util.concurrent.ListenableFuture<Lease>