io.rsocket

public Interface Closeable

Known Direct Subinterfaces: io.rsocket.DuplexConnection, io.rsocket.RSocket, io.rsocket.core.RSocketClient, io.rsocket.resume.ResumableFramesStore
Known Direct Implementers: io.rsocket.core.ClientServerInputMultiplexer, io.rsocket.loadbalance.RSocketPool
Imports: org.reactivestreams.Subscriber, reactor.core.Disposable, reactor.core.publisher.Mono

An interface which allows listening to when a specific instance of this interface is closed

Method Summary

Modifier and Type	Method and Description
public Mono<Void>	Returns: a `Mono` to track completion with success or error of the underlying resource. When the underlying resource is an `RSocket`, the `Mono` exposes stream 0 (i.e. connection level) errors. onClose() Returns a `Mono` that terminates when the instance is terminated by any reason.

onClose back to summary

onClose	back to summary
public Mono<Void> onClose() Returns a `Mono` that terminates when the instance is terminated by any reason. Note, in case of error termination, the cause of error will be propagated as an error signal through `org.reactivestreams.Subscriber#onError(Throwable)`. Otherwise, `Subscriber#onComplete()` will be called. Returns:Mono<Void> a `Mono` to track completion with success or error of the underlying resource. When the underlying resource is an `RSocket`, the `Mono` exposes stream 0 (i.e. connection level) errors.

public Mono<Void> onClose()

Returns a Mono that terminates when the instance is terminated by any reason. Note, in case of error termination, the cause of error will be propagated as an error signal through org.reactivestreams.Subscriber#onError(Throwable). Otherwise, Subscriber#onComplete() will be called.

Returns:Mono<Void>: a Mono to track completion with success or error of the underlying resource. When the underlying resource is an `RSocket`, the Mono exposes stream 0 (i.e. connection level) errors.