org.axonframework.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 and 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 Detail

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