Package org.axonframework.messaging.queryhandling

Interface SinkWrapper<T>

public interface SinkWrapper<T>
Abstraction interface to bridge old FluxSink and Sinks.Many API with a common API.
Since:
4.5
Author:
Stefan Dragisic

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    complete()
    Wrapper around Sink complete().
    void
    error(Throwable t)
    Wrapper around Sink error(Throwable).
    void
    next(T value)
    Wrapper around Sink next(Object).

  • Method Details

    • complete

      void complete()
      Wrapper around Sink complete().

    • next

      void next(T value)
      Wrapper around Sink next(Object).
      Parameters:
      value - to be passed to the delegate sink

    • error

      void error(Throwable t)
      Wrapper around Sink error(Throwable).
      Parameters:
      t - to be passed to the delegate sink