Class TokenGateBlock<T>

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

public class TokenGateBlock<T> : AbstractEncapsulatedTargetBlock<T>, ITargetBlock<T>, IDataflowBlock

Type Parameters

T

Inheritance

object

AbstractEncapsulatedDataflowBlock

AbstractEncapsulatedTargetBlock<T>

TokenGateBlock<T>

Implements

ITargetBlock<T>

IDataflowBlock

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

PipelineBuilderExtensions.Pipeline<TBlock>(TBlock)

Constructors

TokenGateBlock(ITargetBlock<T>, Action<int>?)

public TokenGateBlock(ITargetBlock<T> inner, Action<int>? onTokenSpent = null)

Parameters

inner ITargetBlock<T>

onTokenSpent Action<int>

Properties

Tokens

Current amount of tokens still available.

public int Tokens { get; }

Property Value

int

Methods

Allow(int)

Allow count new messages to be delivered (either synchronously or asynchronously) by the linked targets. /

public void Allow(int count = 1)

Parameters

count int