Package | Description |
---|---|
reactor.io.net |
Reactive network components are located in this package scope implementing the following exposed contract:
A
ReactorPeer NetServer/NetClient is a Publisher of
ReactorChannel that are themselves Publisher of input data. |
reactor.io.net.impl.netty |
Implementations of the various TCP abstractions based on Netty.
|
reactor.io.net.impl.netty.http | |
reactor.io.net.impl.zmq |
Modifier and Type | Method and Description |
---|---|
ReactorChannel.ConsumerSpec |
ReactorChannel.ConsumerSpec.close(Consumer<Void> onClose)
Assign a
Runnable to be invoked when the channel is closed. |
ReactorChannel.ConsumerSpec |
ReactorChannel.on()
Assign event handlers to certain channel lifecycle events.
|
ReactorChannel.ConsumerSpec |
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 |
ReactorChannel.ConsumerSpec.writeIdle(long idleTimeout,
Consumer<Void> onWriteIdle)
Assign a
Runnable to be invoked when writes have become idle for the given timeout. |
Modifier and Type | Method and Description |
---|---|
ReactorChannel.ConsumerSpec |
NettyChannelStream.on() |
Modifier and Type | Method and Description |
---|---|
ReactorChannel.ConsumerSpec |
NettyHttpChannel.on() |
Modifier and Type | Method and Description |
---|---|
ReactorChannel.ConsumerSpec |
ZeroMQChannelStream.on() |
Copyright © 2016. All rights reserved.