BufferingEventPipeline

java.lang.Object

org.jgrapes.core.internal.BufferingEventPipeline

All Implemented Interfaces:: Components.IdInfoProvider

public class BufferingEventPipeline extends Object

The buffering event pipeline is used before a tree has been started.

It simply buffers all events until a Start event is added.

Method Summary

Modifier and Type

Method

Description

<T extends Event<?>> T

add(T event, Channel... channels)

void

awaitExhaustion()

ExecutorService

executorService()

default Class<?>

idScope()

All pipelines use the same id scope to make them uniquely identifiable by their number.

void

merge(org.jgrapes.core.internal.InternalEventPipeline other)

String

toString()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jgrapes.core.Components.IdInfoProvider
idObject

Method Details
- merge
  
  public void merge(org.jgrapes.core.internal.InternalEventPipeline other)
- add
  
  public <T extends Event<?>> T add(T event, Channel... channels)
- awaitExhaustion
  
  public void awaitExhaustion() throws InterruptedException
  
  Throws:
  
  InterruptedException
- executorService
  
  public ExecutorService executorService()
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object
- idScope
  
  default Class<?> idScope()
  
  All pipelines use the same id scope to make them uniquely identifiable by their number.
  
  Specified by:
  
  idScope in interface Components.IdInfoProvider
  
  Returns:
  
  the scope