Интерфейс 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

Параметры:

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

Вызывает исключение:

IllegalArgumentException — если время ожидания отрицательное

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

См. также:

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

void awaitTermination() throws InterruptedException

Вызывает исключение:

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

См. также:

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