@FunctionalInterface public interface DisposableChannel extends Disposable
Disposable.Composite, Disposable.Swap
Modifier and Type | Method and Description |
---|---|
default InetSocketAddress |
address()
Return local server selector channel address.
|
Channel |
channel()
Return the underlying
Channel . |
default void |
dispose()
Release or close the underlying
Channel |
default void |
disposeNow()
Release or close the underlying
Channel in a blocking fashion with 3
seconds default timeout. |
default void |
disposeNow(java.time.Duration timeout)
Release or close the underlying
Channel in a blocking fashion |
default CoreSubscriber<Void> |
disposeSubscriber()
Return a
CoreSubscriber that will dispose on complete or error |
default boolean |
isDisposed() |
default Mono<Void> |
onDispose()
Return an observing
Mono terminating with success when shutdown
successfully or error. |
default DisposableChannel |
onDispose(Disposable onDispose)
Assign a
Disposable to be invoked when the channel is closed. |
default InetSocketAddress address()
InetSocketAddress
Channel channel()
Channel
. Direct interaction might be considered
insecure if that affects the underlying IO processing such as read, write or close
or state such as pipeline handler addition/removal.Channel
default void dispose()
Channel
dispose
in interface Disposable
default void disposeNow()
Channel
in a blocking fashion with 3
seconds default timeout.default void disposeNow(java.time.Duration timeout)
Channel
in a blocking fashiondefault CoreSubscriber<Void> disposeSubscriber()
CoreSubscriber
that will dispose on complete or errordefault boolean isDisposed()
isDisposed
in interface Disposable
default Mono<Void> onDispose()
Mono
terminating with success when shutdown
successfully or error.Mono
terminating with success if shutdown successfully or errordefault DisposableChannel onDispose(Disposable onDispose)
Disposable
to be invoked when the channel is closed.onDispose
- the close event handler