public class BeamFnDataTimeBasedBufferingOutboundObserver<T> extends BeamFnDataSizeBasedBufferingOutboundObserver<T>
FnDataReceiver
with both size-based buffer and time-based buffer
enabled for the Beam Fn Data API.BEAM_FN_API_DATA_BUFFER_LIMIT, BEAM_FN_API_DATA_BUFFER_SIZE_LIMIT, BEAM_FN_API_DATA_BUFFER_TIME_LIMIT, DATA_BUFFER_SIZE_LIMIT, DATA_BUFFER_TIME_LIMIT_MS, DEFAULT_BUFFER_LIMIT_BYTES, DEFAULT_BUFFER_LIMIT_TIME_MS
Modifier and Type | Method and Description |
---|---|
void |
accept(T t) |
void |
close()
.
|
void |
flush()
Eagerly flushes any data that is buffered in this channel.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forLocation, getSizeLimit, getTimeLimit
public void close() throws java.lang.Exception
CloseableFnDataReceiver
Does nothing if this CloseableFnDataReceiver
is already closed.
close
in interface java.lang.AutoCloseable
close
in interface CloseableFnDataReceiver<T>
close
in class BeamFnDataSizeBasedBufferingOutboundObserver<T>
java.lang.Exception
public void flush() throws java.io.IOException
CloseableFnDataReceiver
flush
in interface CloseableFnDataReceiver<T>
flush
in class BeamFnDataSizeBasedBufferingOutboundObserver<T>
java.io.IOException
public void accept(T t) throws java.io.IOException
accept
in interface FnDataReceiver<T>
accept
in class BeamFnDataSizeBasedBufferingOutboundObserver<T>
java.io.IOException