Class/Object

org.openmole.core.workflow.transition

DataChannel

Related Docs: object DataChannel | package transition

Permalink

class DataChannel extends AnyRef

A data channel allow to transmit data between remotes task capsules within a mole. Two capsules could be linked with a DataChannel if:

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DataChannel
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DataChannel(start: Capsule, end: Slot, filter: BlockList)

    Permalink

    start

    the capsule from which the data channel starts

    end

    the capsule to which the data channel ends

    filter

    the filter of the variable transported by this data channel

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  6. def consums(ticket: Ticket, moleExecution: MoleExecution): Iterable[Variable[_]]

    Permalink

    Consums the provided variables and construct a context for them.

    Consums the provided variables and construct a context for them.

    ticket

    the ticket of the current execution

    moleExecution

    the current mole execution

    returns

    the variables which have been transmitted through this data channel

  7. def data(mole: Mole, sources: Sources, hooks: Hooks): Iterable[Val[_]]

    Permalink

    Get the set of data of that will actually be transmitted as input to the ending task capsule.

    Get the set of data of that will actually be transmitted as input to the ending task capsule. This is computed by intersecting the set of variable names transported by this data channel and the set of input of the ending task.

    returns

    the transmitted data

  8. val end: Slot

    Permalink

    the capsule to which the data channel ends

  9. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  10. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  11. val filter: BlockList

    Permalink

    the filter of the variable transported by this data channel

  12. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  13. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  14. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  15. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  16. def levelDelta(mole: Mole): Int

    Permalink

  17. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  18. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  19. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  20. def provides(fromContext: Context, ticket: Ticket, moleExecution: MoleExecution): Iterable[_ >: (DataChannel, Buffer[Variable[_]]) with Variable[_$1] forSome {type _$1} <: AnyRef] with PartialFunction[DataChannel with Int, AnyRef] with Cloneable with Growable[(DataChannel, Buffer[Variable[_]]) with Variable[_$1] forSome {type _$1}] with Shrinkable[DataChannel with Variable[_$1] forSome {type _$1}] { def seq: scala.collection.mutable.Iterable[_ >: (org.openmole.core.workflow.transition.DataChannel, scala.collection.mutable.Buffer[org.openmole.core.context.Variable[_]]) with org.openmole.core.context.Variable[_$1] forSome { type _$1 } <: Object] with scala.collection.mutable.Cloneable[scala.collection.mutable.Iterable[_ >: (org.openmole.core.workflow.transition.DataChannel, scala.collection.mutable.Buffer[org.openmole.core.context.Variable[_]]) with org.openmole.core.context.Variable[_$1] forSome { type _$1 } <: Object] with scala.collection.mutable.Cloneable[scala.collection.mutable.Iterable[_ >: (org.openmole.core.workflow.transition.DataChannel, scala.collection.mutable.Buffer[org.openmole.core.context.Variable[_]]) with org.openmole.core.context.Variable[_$1] forSome { type _$1 } <: Object] with scala.collection.mutable.Cloneable[Cloneable with Mutable with Equals] with PartialFunction[org.openmole.core.workflow.transition.DataChannel with Int,Object]{def seq: Cloneable with Mutable with Equals}] with PartialFunction[org.openmole.core.workflow.transition.DataChannel with Int,Object]{def seq: scala.collection.mutable.Iterable[_ >: (org.openmole.core.workflow.transition.DataChannel, scala.collection.mutable.Buffer[org.openmole.core.context.Variable[_]]) with org.openmole.core.context.Variable[_$1] forSome { type _$1 } <: Object] with scala.collection.mutable.Cloneable[Cloneable with Mutable with Equals] with PartialFunction[org.openmole.core.workflow.transition.DataChannel with Int,Object]{def seq: Cloneable with Mutable with Equals}}] with PartialFunction[org.openmole.core.workflow.transition.DataChannel with Int,Object]{def seq: scala.collection.mutable.Iterable[_ >: (org.openmole.core.workflow.transition.DataChannel, scala.collection.mutable.Buffer[org.openmole.core.context.Variable[_]]) with org.openmole.core.context.Variable[_$1] forSome { type _$1 } <: Object] with scala.collection.mutable.Cloneable[scala.collection.mutable.Iterable[_ >: (org.openmole.core.workflow.transition.DataChannel, scala.collection.mutable.Buffer[org.openmole.core.context.Variable[_]]) with org.openmole.core.context.Variable[_$1] forSome { type _$1 } <: Object] with scala.collection.mutable.Cloneable[Cloneable with Mutable with Equals] with PartialFunction[org.openmole.core.workflow.transition.DataChannel with Int,Object]{def seq: Cloneable with Mutable with Equals}] with PartialFunction[org.openmole.core.workflow.transition.DataChannel with Int,Object]{def seq: scala.collection.mutable.Iterable[_ >: (org.openmole.core.workflow.transition.DataChannel, scala.collection.mutable.Buffer[org.openmole.core.context.Variable[_]]) with org.openmole.core.context.Variable[_$1] forSome { type _$1 } <: Object] with scala.collection.mutable.Cloneable[Cloneable with Mutable with Equals] with PartialFunction[org.openmole.core.workflow.transition.DataChannel with Int,Object]{def seq: Cloneable with Mutable with Equals}}} }

    Permalink

    Provides the variable for future consuption by the matching execution of the ending task.

    Provides the variable for future consuption by the matching execution of the ending task.

    fromContext

    the context containing the variables

    ticket

    the ticket of the current execution

    moleExecution

    the current mole execution

  21. val start: Capsule

    Permalink

    the capsule from which the data channel starts

  22. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  23. def toString(): String

    Permalink
    Definition Classes
    DataChannel → AnyRef → Any

  24. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  25. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  26. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped