package org.axonframework.queryhandling;

/**
 * Abstraction interface to bridge old FluxSink and SinksMany API
 * with common API..
 *
 * @author Stefan Dragisic
 * @since 4.5
 */
public interface SinkWrapper<T> {

    /**
     * Wrapper around Sink complete().
     */
    public void complete();

    /**
     * Wrapper around Sink next(Object).
     *
     * @param value to be passed to the delegate sink
     */
    public void next(T value);

    /**
     * Wrapper around Sink error(Throwable).
     *
     * @param t to be passed to the delegate sink
     */
    public void error(Throwable t);


}

@@ -82,16 +82,23 @@
 old 
+%7B@code 
 FluxSink
  and
@@ -97,13 +97,21 @@
 Sink
+%7D
  and 
+%7B@link 
 Sink
@@ -115,16 +115,17 @@
 inksMany
+%7D
  API%0A * 
@@ -129,16 +129,18 @@
  * with 
+a 
 common A
@@ -142,17 +142,16 @@
 mon API.
-.
 %0A *%0A * @

Update messaging/src/main/java/org/axonframework/queryhandling/SinkWrapper.java