Class FlowNode_ObservableSubscribeT<T>

Namespace

Ceres.Flow.Utilities

Assembly

Ceres.Flow.dll

[CeresGroup("Utilities/Rx")]
[CeresLabel("Subscribe")]
[NodeInfo("Subscribes to an observable source and invokes the callback for each value.")]
public class FlowNode_ObservableSubscribeT<T> : FlowNode, IEnumerable<CeresNode>, IEnumerable, IDisposable

Type Parameters

T

Inheritance

object

CeresNode

ExecutableNode

ForwardNode

FlowNode

FlowNode_ObservableSubscribeT<T>

Implements

IEnumerable<CeresNode>

IEnumerable

IDisposable

Inherited Members

FlowNode.exec

FlowNode.Execute(ExecutionContext)

ForwardNode.input

ExecutableNode.ExecuteNode(ExecutionContext)

ExecutableNode.Graph

CeresNode.SharedVariables

CeresNode.Ports

CeresNode.PortLists

CeresNode.Dispose()

CeresNode.GetSerializedData()

CeresNode.GetExecutionPath()

CeresNode.GetEnumerator()

CeresNode.GetExecutionPath(Type)

CeresNode.MakeSubtitle(string, bool)

CeresNode.GetTargetSubtitle(string, bool)

CeresNode.GetTargetSubtitle(Type, bool)

CeresNode.GetTypeName()

CeresNode.NodeData

CeresNode.Guid

CeresNode.GraphPosition

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

FlowNode_ObservableSubscribeT()

public FlowNode_ObservableSubscribeT()

Fields

onNext

[InputPort(false)]
public DelegatePort<EventDelegate<T>> onNext

Field Value

DelegatePort<EventDelegate<T>>

subject

[InputPort(true)]
[HideInGraphEditor]
public CeresPort<Observable<T>> subject

Field Value

CeresPort<Observable<T>>

subscription

[OutputPort(true)]
public CeresPort<IDisposable> subscription

Field Value

CeresPort<IDisposable>

Methods

LocalExecute(ExecutionContext)

Do node local execution, sync only

protected override void LocalExecute(ExecutionContext executionContext)

Parameters

executionContext ExecutionContext

__getTypeName()

protected override string __getTypeName()

Returns

string

__initializePorts()

protected override void __initializePorts()

__initializeVariables()

protected override void __initializeVariables()