Package io.micronaut.data.connection.reactive

Interface ReactiveConnectionSynchronization

public interface ReactiveConnectionSynchronization
Interface for the reactive connection synchronization callbacks.
Since:
4.2.0
Author:
Denis Stepanov

  • Method Summary

    Modifier and Type
    Method
    Description
    default org.reactivestreams.Publisher<Void>
    afterClose()
    Invoked after the connection is closed.
    default org.reactivestreams.Publisher<Void>
    onCancel()
    Invoked when the connection operation is canceled.
    default org.reactivestreams.Publisher<Void>
    onClose()
    Invoked before the connection is closed.
    default org.reactivestreams.Publisher<Void>
    onComplete()
    Invoked when the connection operation execution is completed.
    default org.reactivestreams.Publisher<Void>
    onError(Throwable throwable)
    Invoked when the connection operation execution throws an exception.

  • Method Details

    • onComplete

      default org.reactivestreams.Publisher<Void> onComplete()
      Invoked when the connection operation execution is completed.
      Returns:
      The publisher

    • onError

      default org.reactivestreams.Publisher<Void> onError(Throwable throwable)
      Invoked when the connection operation execution throws an exception.
      Returns:
      The publisher

    • onCancel

      default org.reactivestreams.Publisher<Void> onCancel()
      Invoked when the connection operation is canceled.
      Returns:
      The publisher

    • onClose

      default org.reactivestreams.Publisher<Void> onClose()
      Invoked before the connection is closed. NOTE: this will be executed only when the physical connection is closed. Ordinary connection can be reused for multiple connection operations.
      Returns:
      The publisher

    • afterClose

      default org.reactivestreams.Publisher<Void> afterClose()
      Invoked after the connection is closed. NOTE: this will be executed only when the physical connection is closed. Ordinary connection can be reused for multiple connection operations.
      Returns:
      The publisher