Package org.drasyl

Class ObservableDrasylNode

java.lang.Object

org.drasyl.DrasylNode

org.drasyl.ObservableDrasylNode

public class ObservableDrasylNode
extends DrasylNode

This particular Implementation of a drasyl Node shows exemplary how incoming Events can be processed using the Observer Pattern.

Constructor Summary

Constructors

Constructor	Description
ObservableDrasylNode()
ObservableDrasylNode(DrasylConfig config)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Observable<Event>	events()
static void	main(String[] args)
void	onEvent(Event event)	Sends event to the application and tells it information about the local node, other peers, connections or incoming messages.

Methods inherited from class org.drasyl.DrasylNode

getBestEventLoop, getBestEventLoop, getVersion, identity, irrevocablyTerminate, pipeline, send, send, shutdown, start

Methods inherited from class java.lang.Object

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

Constructor Details

ObservableDrasylNode

public ObservableDrasylNode()
                     throws DrasylException

Throws:

DrasylException

ObservableDrasylNode

public ObservableDrasylNode(DrasylConfig config)
                     throws DrasylException

Throws:

DrasylException

Method Details

onEvent

public void onEvent(Event event)

Description copied from class: DrasylNode

Sends event to the application and tells it information about the local node, other peers, connections or incoming messages.

Specified by:

onEvent in class DrasylNode

Parameters:

event - the event

main

public static void main(String[] args)
                 throws DrasylException

Throws:

DrasylException

events

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