ome.smuggler.core.msg

Class OnceOffSchedule<T>

java.lang.Object

ome.smuggler.core.msg.OnceOffSchedule<T>

All Implemented Interfaces:

Reschedulable<T>

public class OnceOffSchedule<T>
extends java.lang.Object
implements Reschedulable<T>

Plugs into a ReschedulingSink to deliver messages to sink's consumers exactly once.

See Also:

MessageRepeater, OnceOffRepeatConsumer

Constructor Summary

Constructors

Constructor and Description
OnceOffSchedule(java.util.function.Consumer<T> consumer) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
java.util.Optional<Schedule<T>>	consume(CountedSchedule current, T data) Consumes the output of the channel this instance is bound to.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OnceOffSchedule

public OnceOffSchedule(java.util.function.Consumer<T> consumer)

Creates a new instance.

Parameters:

consumer - consumes the message output from the channel.

Throws:

java.lang.NullPointerException - if the argument is null.

Method Detail

consume

public java.util.Optional<Schedule<T>> consume(CountedSchedule current,
                                               T data)

Description copied from interface: Reschedulable

Consumes the output of the channel this instance is bound to.

Specified by:

consume in interface Reschedulable<T>

Parameters:

current - information about this invocation's schedule.

data - the data received from the channel.

Returns:

when and what data to input again in the channel or empty if no further action is required. Never return null.