Package org.drasyl.pipeline

Class EmbeddedPipeline

java.lang.Object

org.drasyl.pipeline.DefaultPipeline

org.drasyl.pipeline.EmbeddedPipeline

All Implemented Interfaces:

Pipeline

public class EmbeddedPipeline
extends DefaultPipeline

Embedded Pipeline implementation, that allows easy testing of Handlers.

Field Summary

Fields inherited from class org.drasyl.pipeline.DefaultPipeline

config, handlerNames, head, identity, inboundValidator, outboundValidator, scheduler, tail

Constructor Summary

Constructors

Constructor	Description
EmbeddedPipeline(Identity identity, TypeValidator inboundValidator, TypeValidator outboundValidator)
EmbeddedPipeline(Identity identity, TypeValidator inboundValidator, TypeValidator outboundValidator, Handler... handlers)	Creates a new embedded pipeline and adds all given handler to it.

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Observable<Event>	inboundEvents()
io.reactivex.rxjava3.core.Observable<Pair<CompressedPublicKey,Object>>	inboundMessages()
<T> io.reactivex.rxjava3.core.Observable<T>	outboundMessages(Class<T> clazz)

Methods inherited from class org.drasyl.pipeline.DefaultPipeline

addAfter, addBefore, addFirst, addLast, context, get, initPointer, processInbound, processInbound, processInbound, processOutbound, remove, replace

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EmbeddedPipeline

public EmbeddedPipeline(Identity identity,
 TypeValidator inboundValidator,
 TypeValidator outboundValidator,
 Handler... handlers)

Creates a new embedded pipeline and adds all given handler to it. Handler are added with their simple class name.

Parameters:

identity - the identity

inboundValidator - the inbound validator

outboundValidator - the outbound validator

handlers - the handlers

EmbeddedPipeline

public EmbeddedPipeline(Identity identity,
 TypeValidator inboundValidator,
 TypeValidator outboundValidator)

Method Details

inboundMessages

public io.reactivex.rxjava3.core.Observable<Pair<CompressedPublicKey,Object>> inboundMessages()

Returns:

all messages that passes the pipeline until the end

inboundEvents

public io.reactivex.rxjava3.core.Observable<Event> inboundEvents()

Returns:

all events that passes the pipeline until the end

outboundMessages

public <T> io.reactivex.rxjava3.core.Observable<T> outboundMessages(Class<T> clazz)

Returns:

all messages that passes the pipeline until the end