ome.smuggler.core.msg

Interface Reschedulable<T>

All Known Implementing Classes:

MessageRepeater, OnceOffSchedule, SessionKeepAliveHandler

public interface Reschedulable<T>

A task that consumes a channel sink's output and optionally requests the channel to deliver again some more data at a later point in time.

See Also:

ReschedulingSink

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.

Method Detail

consume

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

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

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.