DirectInputSubscriber

org.eso.ias.dasu.subscriber.DirectInputSubscriber

The input subscriber to send event to the listener

This subscriber, especially useful for testing, allows to programmatically submit inputs that will be immediately sent to the listener.

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def cleanUpSubscriber(): Try[Unit]

CleanUp and release the resources

CleanUp and release the resources

Attributes

def initializeSubscriber(): Try[Unit]

Initialize

Initialize

Attributes

def isClosed: Boolean

Attributes

Returns

true if it has been closed; false otherwise

def isInitialized: Boolean

Attributes

Returns

true if it has been initialized; false otherwise

def sendInputs(iasios: Set[IASValue[_]]): Unit

Send the passed inputs to the listener

Send the passed inputs to the listener

Value parameters

iasios

the inputs to be processed by the DASU

Attributes

def startSubscriber(listener: InputsListener, acceptedInputs: Set[String]): Try[Unit]

Start to get events and forward them to the listener.

Start to get events and forward them to the listener.

IASIOs whose ID is not in the acceptedInputs set are discarded.

Value parameters

acceptedInputs

the IDs of the inputs accepted by the listener (if empty accepts all the inputs)

listener

the listener of events

Attributes

Concrete fields

val logger: Logger

The logger

The logger

Attributes