org.osgi.util.pushstream

Interface PushEventConsumer<T>

Type Parameters:

T - The type for the event payload

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@ConsumerType
 @FunctionalInterface
public interface PushEventConsumer<T>

An Async Event Consumer asynchronously receives Data events until it receives either a Close or Error event.

Field Summary

Fields

Modifier and Type	Field and Description
static long	ABORT If ABORT is used as return value, the sender should close the channel all the way to the upstream source.
static long	CONTINUE A 0 indicates that the consumer is willing to receive subsequent events at full speeds.

Method Summary

Modifier and Type	Method and Description
long	accept(PushEvent<? extends T> event) Accept an event from a source.

Field Detail

ABORT

static final long ABORT

If ABORT is used as return value, the sender should close the channel all the way to the upstream source. The ABORT will not guarantee that no more events are delivered since this is impossible in a concurrent environment. The consumer should accept subsequent events and close/clean up when the Close or Error event is received. Though ABORT has the value -1, any value less than 0 will act as an abort.

See Also:

Constant Field Values

CONTINUE

static final long CONTINUE

A 0 indicates that the consumer is willing to receive subsequent events at full speeds. Any value more than 0 will indicate that the consumer is becoming overloaded and wants a delay of the given milliseconds before the next event is sent. This allows the consumer to pushback the event delivery speed.

See Also:

Constant Field Values

Method Detail

accept

long accept(PushEvent<? extends T> event)
     throws java.lang.Exception

Accept an event from a source. Events can be delivered on multiple threads simultaneously. However, Close and Error events are the last events received, no more events must be sent after them.

Parameters:

event - The event

Returns:

less than 0 means abort, 0 means continue, more than 0 means delay ms

Throws:

java.lang.Exception - to indicate that an error has occurred and that no further events should be delivered to this PushEventConsumer