Class InMemoryPipelineSource<T>

Namespace

Pipelinez.Core.Source

Assembly

Pipelinez.dll

Provides a minimal in-memory source for tests and simple manual publication scenarios.

public class InMemoryPipelineSource<T> : PipelineSourceBase<T>, IPipelineSource<T>, IFlowSource<PipelineContainer<T>>, IPipelineExecutionConfigurable where T : PipelineRecord

Type Parameters

T

Inheritance

object

PipelineSourceBase<T>

InMemoryPipelineSource<T>

Implements

IPipelineSource<T>

IFlowSource<PipelineContainer<T>>

IPipelineExecutionConfigurable

Inherited Members

PipelineSourceBase<T>.Logger

PipelineSourceBase<T>.ConnectTo(IFlowDestination<PipelineContainer<T>>, DataflowLinkOptions)

PipelineSourceBase<T>.StartAsync(CancellationTokenSource)

PipelineSourceBase<T>.PublishAsync(T)

PipelineSourceBase<T>.PublishAsync(T, PipelinePublishOptions)

PipelineSourceBase<T>.PublishAsync(T, MetadataCollection)

PipelineSourceBase<T>.PublishAsync(T, MetadataCollection, PipelinePublishOptions)

PipelineSourceBase<T>.Complete()

PipelineSourceBase<T>.Completion

PipelineSourceBase<T>.Initialize(Pipeline<T>)

PipelineSourceBase<T>.OnPipelineContainerComplete(object, PipelineContainerCompletedEventHandlerArgs<PipelineContainer<T>>)

PipelineSourceBase<T>.ConfigureExecutionOptions(PipelineExecutionOptions)

PipelineSourceBase<T>.GetExecutionOptions()

PipelineSourceBase<T>.ParentPipeline

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Initialize()

Provides an opportunity for the source to initialize transport-specific state.

protected override void Initialize()

MainLoop(CancellationTokenSource)

Executes the main source loop.

protected override Task MainLoop(CancellationTokenSource cancellationToken)

Parameters

cancellationToken CancellationTokenSource

The runtime cancellation source used to stop the source.

Returns

Task

A task that completes when the source loop exits.