Read
- Type of objects read from this connection.Write
- Type of objects written to this connection.public interface NettyConnection<Read,Write> extends NettyConnectionContext
Publisher
.NettyConnectionContext.FlushStrategyProvider
ConnectionInfo.Protocol
Modifier and Type | Method and Description |
---|---|
Publisher<Read> |
read()
Returns
Publisher that emits all items as read from this connection. |
Completable |
write(Publisher<Write> write)
Writes all elements emitted by the passed
Publisher on this connection. |
Completable |
write(Publisher<Write> write,
java.util.function.Supplier<FlushStrategy> flushStrategySupplier,
java.util.function.Supplier<WriteDemandEstimator> demandEstimatorSupplier)
Writes all elements emitted by the passed
Publisher on this connection. |
defaultFlushStrategy, nettyChannel, onClosing, transportError, updateFlushStrategy
executionContext, localAddress, protocol, remoteAddress, socketOption, sslSession
onClose
closeAsync, closeAsyncGracefully
Publisher<Read> read()
Publisher
that emits all items as read from this connection.Publisher
that emits all items as read from this connection.
Concurrent subscribes when a PublisherSource.Subscriber
is already active) are disallowed but sequential subscribes when
a previous PublisherSource.Subscriber
has terminated) are allowed.Completable write(Publisher<Write> write)
Publisher
on this connection.write
- Publisher
, all objects emitted from which are written on this connection.Completable
that terminates as follows:
Completable write(Publisher<Write> write, java.util.function.Supplier<FlushStrategy> flushStrategySupplier, java.util.function.Supplier<WriteDemandEstimator> demandEstimatorSupplier)
Publisher
on this connection.write
- Publisher
, all objects emitted from which are written on this connection.flushStrategySupplier
- Supplier
of FlushStrategy
which controls the flush operations
for this write.demandEstimatorSupplier
- A Supplier
of WriteDemandEstimator
for this write.Completable
that terminates as follows: