org.tikv.common.util

Class FutureObserver<Value,RespT>

java.lang.Object

org.tikv.common.util.FutureObserver<Value,RespT>

All Implemented Interfaces:

io.grpc.stub.StreamObserver<RespT>

public class FutureObserver<Value,RespT>
extends Object
implements io.grpc.stub.StreamObserver<RespT>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	FutureObserver.Getter<Value,RespT>

Constructor Summary

Constructors

Constructor and Description
FutureObserver(FutureObserver.Getter<Value,RespT> getter)

Method Summary

Modifier and Type	Method and Description
Future<Value>	getFuture()
Value	getValue(RespT resp)
void	onCompleted()
void	onError(Throwable t)
void	onNext(RespT resp)

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureObserver

public FutureObserver(FutureObserver.Getter<Value,RespT> getter)

Method Detail

getValue

public Value getValue(RespT resp)

onNext

public void onNext(RespT resp)

Specified by:

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

onError

public void onError(Throwable t)

Specified by:

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

onCompleted

public void onCompleted()

Specified by:

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

getFuture

public Future<Value> getFuture()