public static interface ReactorChannel.ConsumerSpec
Modifier and Type | Method and Description |
---|---|
ReactorChannel.ConsumerSpec |
close(Consumer<Void> onClose)
Assign a
Runnable to be invoked when the channel is closed. |
ReactorChannel.ConsumerSpec |
readIdle(long idleTimeout,
Consumer<Void> onReadIdle)
Assign a
Runnable to be invoked when reads have become idle for the given timeout. |
ReactorChannel.ConsumerSpec |
writeIdle(long idleTimeout,
Consumer<Void> onWriteIdle)
Assign a
Runnable to be invoked when writes have become idle for the given timeout. |
ReactorChannel.ConsumerSpec close(Consumer<Void> onClose)
Runnable
to be invoked when the channel is closed.onClose
- the close event handlerReactorChannel.ConsumerSpec readIdle(long idleTimeout, Consumer<Void> onReadIdle)
Runnable
to be invoked when reads have become idle for the given timeout.idleTimeout
- the idle timeoutonReadIdle
- the idle timeout handlerReactorChannel.ConsumerSpec writeIdle(long idleTimeout, Consumer<Void> onWriteIdle)
Runnable
to be invoked when writes have become idle for the given timeout.idleTimeout
- the idle timeoutonWriteIdle
- the idle timeout handlerCopyright © 2017. All rights reserved.