alluxio.client.block.stream

Class DefaultBlockWorkerClient.NoDataReadStreamObserver

java.lang.Object

alluxio.client.block.stream.DefaultBlockWorkerClient.NoDataReadStreamObserver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<ReadResponse>

Enclosing class:

DefaultBlockWorkerClient

public static class DefaultBlockWorkerClient.NoDataReadStreamObserver
extends Object
implements io.grpc.stub.StreamObserver<ReadResponse>

No data read stream observer.

Constructor Summary

Constructors

Constructor and Description
NoDataReadStreamObserver()

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Object>	getFuture()
void	onCompleted()
void	onError(Throwable t)
void	onNext(ReadResponse response)

Methods inherited from class java.lang.Object

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

Constructor Detail

NoDataReadStreamObserver

public NoDataReadStreamObserver()

Method Detail

onNext

public void onNext(ReadResponse response)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<ReadResponse>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<ReadResponse>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<ReadResponse>

getFuture

public com.google.common.util.concurrent.ListenableFuture<Object> getFuture()

Returns:

future