Package s2.v1alpha

Class StreamServiceGrpc.StreamServiceFutureStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<StreamServiceGrpc.StreamServiceFutureStub>
s2.v1alpha.StreamServiceGrpc.StreamServiceFutureStub
Enclosing class:
StreamServiceGrpc
public static final class StreamServiceGrpc.StreamServiceFutureStub extends io.grpc.stub.AbstractFutureStub<StreamServiceGrpc.StreamServiceFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service StreamService. 
 Operate on an S2 stream.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

    io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

  • Method Summary

    Modifier and Type
    Method
    Description
    com.google.common.util.concurrent.ListenableFuture<AppendResponse>
    append(AppendRequest request)
    Append a batch of records to a stream.
    protected StreamServiceGrpc.StreamServiceFutureStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    com.google.common.util.concurrent.ListenableFuture<CheckTailResponse>
    checkTail(CheckTailRequest request)
    Check the sequence number that will be assigned to the next record on a stream.
    com.google.common.util.concurrent.ListenableFuture<ReadResponse>
    read(ReadRequest request)
    Retrieve a batch of records from a stream.

    Methods inherited from class io.grpc.stub.AbstractFutureStub

    newStub, newStub

    Methods inherited from class io.grpc.stub.AbstractStub

    getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait