root
API
Generated with
root/org.eso.ias/org.eso.ias.dasu/org.eso.ias.dasu.test/Dasu7ASCEsTest/Fixture

Fixture

org.eso.ias.dasu.test.Dasu7ASCEsTest.Fixture
trait Fixture

Fixture to build same type of objects for the tests

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Type members

Classlikes

class TestListener extends OutputListener

The listener of outputs produced by the DASU.

The listener of outputs produced by the DASU.

It allows to wait for a given number of outputs by setting the optional CountDownLatch

Attributes

Supertypes
class Object
trait Matchable
class Any

Value members

Concrete methods

def buildValue(id: String, fullRunningID: String, d: Double): IASValue[_]
def buildValue(id: String, fullRunningID: String, d: Double, validity: IasValidity): IASValue[_]
def waitDasuProcessedAllInputs(timeout: Int): Boolean

A function to wait until the DASU has processed all the inputs or the timeout expires.

A function to wait until the DASU has processed all the inputs or the timeout expires.

This function works if no new inputs are submitted to the DASU while waiting. The DASU does not offer a function for checking the state of the computation so this function actively wait on the inputs to be processed and the on the presence of scheduled tasks to process the output.

Attributes

Concrete fields

val cdbFiles: CdbFiles
val cdbParentPath: Path
val cdbReader: CdbReader
val dasu: DasuImpl
val dasuDao: DasuDao
val dasuId: String
val eventsReceived: AtomicInteger

The number of events received This is the number of output generated by the DASU after running the TF on all its ASCEs

The number of events received This is the number of output generated by the DASU after running the TF on all its ASCEs

Attributes

val iasValuesReceived: ListBuffer[IASValue[_]]
val stringSerializer: Option[IasValueJsonSerializer]
val strsReceived: AtomicInteger

The number of JSON strings received

The number of JSON strings received

Attributes

Generated with