Интерфейс EventStream

static EventStream openRepository() throws IOException

Возвращает:

поток событий, не null

Исключения:

IOException - если поток не может быть открыт или возникает ошибка ввода-вывода при попытке доступа к репозиторию

static EventStream openRepository(Path directory) throws IOException

Параметры:

directory - расположение дискового репозитория, не null

Возвращает:

поток событий, не null

Исключения:

IOException - если поток не может быть открыт или возникает ошибка ввода-вывода при попытке доступа к репозиторию

static EventStream openFile(Path file) throws IOException

Параметры:

file - расположение файла, не null

Возвращает:

поток событий, не null

Исключения:

IOException - если файл не может быть открыт или возникает ошибка ввода-вывода во время чтения

default void onMetadata(Consumer<MetadataEvent> action)

static long count = 0;
public static void main(String... args) throws IOException {
    Path file = Path.of(args[0]);
    String regExp = args[1];
    var pr = Pattern.compile(regExp).asMatchPredicate();
    try (var s = EventStream.openFile(file)) {
        s.setOrdered(false);
        s.onMetadata(metadata -> metadata.getAddedEventTypes()
         .stream().map(EventType::getName).filter(pr)
         .forEach(eventName -> s.onEvent(eventName, event -> count++)));
        s.start();
        System.out.println(count + " events matches " + regExp);
    }
}

Требования к реализации:

Реализация этого метода по умолчанию пуста.

Параметры:

action - для выполнения, не null

Исключения:

IllegalStateException - если действие добавляется после запуска потока

С версии:

16

void onEvent(Consumer<RecordedEvent> action)

Параметры:

action - действие, которое нужно выполнить для каждого RecordedEvent, не null

См. также:

• onEvent(Consumer)
• onMetadata(Consumer)

void onEvent(String eventName, Consumer<RecordedEvent> action)

Параметры:

eventName - имя события, не null

action - действие, которое нужно выполнить для каждого RecordedEvent, соответствующего имени события, не null

void onFlush(Runnable action)

Параметры:

action - действие, которое нужно выполнить после очистки потока, не null

void onError(Consumer<Throwable> action)

Параметры:

action - действие, которое нужно выполнить при возникновении исключения, не null

void onClose(Runnable action)

Параметры:

action - действие, которое нужно выполнить после закрытия потока, не null

См. также:

• close()

void close()

Указано в:

close в интерфейсе AutoCloseable

boolean remove(Object action)

Параметры:

action - действие, регистрацию которого нужно отменить, не null

Возвращает:

true если действие было отменено, false в противном случае

См. также:

• onEvent(Consumer)
• onEvent(String, Consumer)
• onFlush(Runnable)
• onClose(Runnable)
• onError(Consumer)

void setReuse(boolean reuse)

Параметры:

reuse - true если объект события может быть повторно использован, false в противном случае

void setOrdered(boolean ordered)

Параметры:

ordered - если объекты событий поступают в хронологическом порядке в onEvent(Consumer)

void setStartTime(Instant startTime)

Параметры:

startTime - время начала, не null

Исключения:

IllegalStateException - если поток уже запущен

См. также:

• start()
• startAsync()

void setEndTime(Instant endTime)

Параметры:

endTime - время окончания, не null

Исключения:

IllegalStateException - если поток уже запущен

См. также:

• start()
• startAsync()

void start()

Исключения:

IllegalStateException - если поток уже запущен или закрыт

void startAsync()

Исключения:

IllegalStateException - если поток уже запущен или закрыт

void awaitTermination(Duration timeout) throws InterruptedException

Parameters:

timeout - максимальное время ожидания, не null

Throws:

IllegalArgumentException - если таймаут отрицательный

InterruptedException - если ожидание было прервано

See Also:

• start()
• startAsync()
• Thread.interrupt()

void awaitTermination() throws InterruptedException

Throws:

InterruptedException - если ожидание было прервано

See Also:

• start()
• startAsync()
• Thread.interrupt()