alluxio.worker.grpc

Class DataMessageServerStreamObserver<T>

java.lang.Object

io.grpc.stub.CallStreamObserver<T>

alluxio.worker.grpc.DataMessageServerStreamObserver<T>

Type Parameters:

T - type of the message

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>

@NotThreadSafe
public class DataMessageServerStreamObserver<T>
extends io.grpc.stub.CallStreamObserver<T>

A StreamObserver for handling raw data buffers.

Constructor Summary

Constructors

Constructor and Description
DataMessageServerStreamObserver(io.grpc.stub.CallStreamObserver<T> observer, BufferRepository<T,DataBuffer> bufferRepository)

Method Summary

Modifier and Type	Method and Description
void	disableAutoInboundFlowControl()
boolean	isReady()
void	onCompleted()
void	onError(Throwable t)
void	onNext(DataMessage<T,DataBuffer> value) Receives a message with data buffer from the stream.
void	onNext(T value)
void	request(int count)
void	setMessageCompression(boolean enable)
void	setOnReadyHandler(Runnable onReadyHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataMessageServerStreamObserver

public DataMessageServerStreamObserver(io.grpc.stub.CallStreamObserver<T> observer,
                                       BufferRepository<T,DataBuffer> bufferRepository)

Parameters:

observer - the original observer

bufferRepository - the repository of the buffers

Method Detail

onNext

public void onNext(DataMessage<T,DataBuffer> value)

Receives a message with data buffer from the stream.

Parameters:

value - the value passed to the stream

onNext

public void onNext(T value)

onError

public void onError(Throwable t)

onCompleted

public void onCompleted()

isReady

public boolean isReady()

Specified by:

isReady in class io.grpc.stub.CallStreamObserver<T>

setOnReadyHandler

public void setOnReadyHandler(Runnable onReadyHandler)

Specified by:

setOnReadyHandler in class io.grpc.stub.CallStreamObserver<T>

disableAutoInboundFlowControl

public void disableAutoInboundFlowControl()

Specified by:

disableAutoInboundFlowControl in class io.grpc.stub.CallStreamObserver<T>

request

public void request(int count)

Specified by:

request in class io.grpc.stub.CallStreamObserver<T>

setMessageCompression

public void setMessageCompression(boolean enable)

Specified by:

setMessageCompression in class io.grpc.stub.CallStreamObserver<T>