public static class F.ArchivedEventStream<T>
extends java.lang.Object
Constructor and Description |
---|
ArchivedEventStream(int archiveSize) |
Modifier and Type | Method and Description |
---|---|
java.util.List<T> |
archive() |
java.util.List<F.IndexedEvent> |
availableEvents(long lastEventSeen) |
F.EventStream<T> |
eventStream() |
F.Promise<java.util.List<F.IndexedEvent<T>>> |
nextEvents(long lastEventSeen) |
void |
publish(T event) |
public F.EventStream<T> eventStream()
public F.Promise<java.util.List<F.IndexedEvent<T>>> nextEvents(long lastEventSeen)
public java.util.List<F.IndexedEvent> availableEvents(long lastEventSeen)
public java.util.List<T> archive()
public void publish(T event)
Guillaume Bort & zenexity - Distributed under Apache 2 licence, without any warrantly