Uses of Interface
org.jgrapes.core.EventPipeline

Packages that use EventPipeline

Package	Description
org.jgrapes.core	Defines the interfaces and classes that provide the core functionality of the JGrapes event driven component framework.
org.jgrapes.core.internal	Classes implementing the public API of the library.
org.jgrapes.io	I/O related components built on top of the core package.
org.jgrapes.io.process	Classes for managing processes.
org.jgrapes.io.util	Utility classes, mainly for adapted buffers to specific needs.
org.jgrapes.net	Networking related I/O classes.

Uses of EventPipeline in org.jgrapes.core

Methods in org.jgrapes.core that return EventPipeline

Modifier and Type	Method	Description
EventPipeline	Manager.activeEventPipeline()	Returns the pipeline used when firing an event.
EventPipeline	Manager.newEventPipeline()	Return a new EventPipeline that processes the added events using a thread from a thread pool.
EventPipeline	Manager.newEventPipeline(ExecutorService executorService)	Return a new EventPipeline that processes the added events using threads from the given executor service.
EventPipeline	EventPipeline.overrideRestriction()	Overrides any restriction set by restrictEventSource(EventPipeline) for the next fire(Event, Channel...) invocation from the calling thread.
EventPipeline	EventPipeline.restrictEventSource(EventPipeline sourcePipeline)	Allow only the given source pipeline to fire events on this pipeline.

Methods in org.jgrapes.core that return types with arguments of type EventPipeline

Modifier and Type	Method	Description
Optional<EventPipeline>	Event.processedBy()	Return the event pipeline that currently processes the event (if any).

Methods in org.jgrapes.core with parameters of type EventPipeline

Modifier and Type	Method	Description
protected void	Event.handlingError(EventPipeline eventProcessor, Throwable throwable)	Implements the default behavior for handling events thrown by a handler.
EventPipeline	EventPipeline.restrictEventSource(EventPipeline sourcePipeline)	Allow only the given source pipeline to fire events on this pipeline.

Uses of EventPipeline in org.jgrapes.core.internal

Methods in org.jgrapes.core.internal that return EventPipeline

Modifier and Type	Method	Description
EventPipeline	ComponentVertex.activeEventPipeline()
EventPipeline	ComponentVertex.newEventPipeline()
EventPipeline	ComponentVertex.newEventPipeline(ExecutorService executorService)

Methods in org.jgrapes.core.internal that return types with arguments of type EventPipeline

Modifier and Type	Method	Description
Optional<EventPipeline>	EventBase.processedBy()

Methods in org.jgrapes.core.internal with parameters of type EventPipeline

Modifier and Type	Method	Description
protected abstract void	EventBase.handlingError(EventPipeline eventProcessor, Throwable throwable)	Invoked when an exception occurs while invoking a handler for an event.

Uses of EventPipeline in org.jgrapes.io

Methods in org.jgrapes.io that return EventPipeline

Modifier and Type	Method	Description
EventPipeline	IOSubchannel.DefaultIOSubchannel.responsePipeline()
EventPipeline	IOSubchannel.responsePipeline()	Gets the EventPipeline that can be used for events going back to the initiator of this connection.

Methods in org.jgrapes.io with parameters of type EventPipeline

Modifier and Type	Method	Description
static IOSubchannel	IOSubchannel.create(Component component, EventPipeline responsePipeline)	Creates a new subchannel of the given component’s channel with the given event pipeline and a buffer pool with two buffers sized 4096.

Constructors in org.jgrapes.io with parameters of type EventPipeline

Modifier	Constructor	Description
	DefaultIOSubchannel(Channel mainChannel, EventPipeline responsePipeline)	Creates a new instance with the given main channel and response pipeline.

Uses of EventPipeline in org.jgrapes.io.process

Methods in org.jgrapes.io.process that return EventPipeline

Modifier and Type	Method	Description
EventPipeline	ProcessManager.ProcessChannel.downPipeline()	Gets the down pipeline.

Uses of EventPipeline in org.jgrapes.io.util

Methods in org.jgrapes.io.util that return EventPipeline

Modifier and Type	Method	Description
EventPipeline	ConnectionManager.Connection.downPipeline()	Gets the down pipeline.

Constructors in org.jgrapes.io.util with parameters of type EventPipeline

Modifier	Constructor	Description
	AbstractBufferWriter(IOSubchannel channel, EventPipeline eventPipeline)	Creates a new instance that uses Output events to dispatch buffers on the given channel, using the given event pipeline.
	BufferedReaderPipeline(BufferedReader in, IOSubchannel channel, EventPipeline eventPipeline)	Creates a new pipeline that sends the lines from the given reader as events on the given channel, using the given event pipeline.
	ByteBufferOutputStream(IOSubchannel channel, EventPipeline eventPipeline)	Creates a new instance that uses Output events to dispatch buffers on the given channel, using the given event pipeline.
	ByteBufferWriter(IOSubchannel channel, EventPipeline eventPipeline)	Creates a new instance that uses Output events to dispatch buffers on the given channel, using the given event pipeline.
	CharBufferWriter(IOSubchannel channel, EventPipeline eventPipeline)	Creates a new instance that uses Output events to dispatch buffers on the given channel, using the given event pipeline.
	InputStreamPipeline(InputStream in, IOSubchannel channel, EventPipeline eventPipeline)	Creates a new pipeline that sends the data from the given input stream as events on the given channel, using the given event pipeline.
	JsonReader(com.fasterxml.jackson.databind.ObjectMapper mapper, Class<R> resultType, EventPipeline pipeline, Channel channel)	Instantiates a new JSON reader.
	JsonReader(Class<R> resultType, EventPipeline pipeline, Channel channel)	Instantiates a new JSON reader that uses a default object mapper.
	LinkedIOSubchannel(Manager hub, Channel mainChannel, IOSubchannel upstreamChannel, EventPipeline responsePipeline)	Creates a new LinkedIOSubchannel for a given main channel that links to the give I/O subchannel.
	LinkedIOSubchannel(Manager hub, Channel mainChannel, IOSubchannel upstreamChannel, EventPipeline responsePipeline, boolean linkBack)	Creates a new LinkedIOSubchannel for a given main channel that links to a given I/O subchannel.

Uses of EventPipeline in org.jgrapes.net

Methods in org.jgrapes.net that return EventPipeline

Modifier and Type	Method	Description
EventPipeline	SocketConnectionManager.SocketChannelImpl.downPipeline()	Gets the down pipeline.