Modifier and Type | Class and Description |
---|---|
pack-priv static class |
Modifier and Type | Field and Description |
---|---|
private Dispatcher. | |
private EventType | |
private final Runnable[] | |
private final LongMap | |
private final Dispatcher. | |
pack-priv final long | |
pack-priv final Instant | |
private final Consumer | |
private final Runnable[] | |
private final Consumer | |
pack-priv final ChunkParser. | |
pack-priv final long | |
pack-priv final Instant |
Access | Constructor and Description |
---|---|
public |
Modifier and Type | Method and Description |
---|---|
private static ParserFilter | |
private void | |
pack-priv void | |
private void | |
public boolean | |
public void | |
public void | |
public void | |
public String |
cacheDispatchers | back to summary |
---|---|
private Dispatcher. |
cacheEventType | back to summary |
---|---|
private EventType cacheEventType |
closeActions | back to summary |
---|---|
private final Runnable[] closeActions |
dispatcherLookup | back to summary |
---|---|
private final LongMap<Dispatcher. |
dispatchers | back to summary |
---|---|
private final Dispatcher. |
endNanos | back to summary |
---|---|
pack-priv final long endNanos |
endTime | back to summary |
---|---|
pack-priv final Instant endTime |
errorActions | back to summary |
---|---|
private final Consumer<Throwable>[] errorActions |
flushActions | back to summary |
---|---|
private final Runnable[] flushActions |
metadataActions | back to summary |
---|---|
private final Consumer<MetadataEvent>[] metadataActions |
parserConfiguration | back to summary |
---|---|
pack-priv final ChunkParser. |
startNanos | back to summary |
---|---|
pack-priv final long startNanos |
startTime | back to summary |
---|---|
pack-priv final Instant startTime |
Dispatcher | back to summary |
---|---|
public Dispatcher(StreamConfiguration c)
|
buildFilter | back to summary |
---|---|
private static ParserFilter buildFilter(Dispatcher. |
defaultErrorHandler | back to summary |
---|---|
private void defaultErrorHandler(Throwable e) |
dispatch | back to summary |
---|---|
pack-priv void dispatch(RecordedEvent event) |
handleError | back to summary |
---|---|
private void handleError(Throwable e) |
hasMetadataHandler | back to summary |
---|---|
public boolean hasMetadataHandler() |
runCloseActions | back to summary |
---|---|
public void runCloseActions() |
runFlushActions | back to summary |
---|---|
public void runFlushActions() |
runMetadataActions | back to summary |
---|---|
public void runMetadataActions(MetadataEvent event) |
toString | back to summary |
---|---|
public String toString() Overrides java. Doc from java. Returns a string representation of the object.
|
Modifier and Type | Field and Description |
---|---|
private final Consumer | |
private final String | |
private static final Dispatcher. |
Access | Constructor and Description |
---|---|
public |
Modifier and Type | Method and Description |
---|---|
private boolean | |
public Consumer | |
private void |
action | back to summary |
---|---|
private final Consumer<RecordedEvent> action |
eventName | back to summary |
---|---|
private final String eventName |
NO_DISPATCHERS | back to summary |
---|---|
private static final Dispatcher. |
EventDispatcher | back to summary |
---|---|
public EventDispatcher(String eventName, Consumer<RecordedEvent> action) |
accepts | back to summary |
---|---|
private boolean accepts(EventType eventType) |
getAction | back to summary |
---|---|
public Consumer |
offer | back to summary |
---|---|
private void offer(RecordedEvent event) |