Fibers<TSource, TValue> Class

Namespace

SatorImaging.UnityFundamentals

public class Fibers<TSource, TValue> : Fibers, IAsyncEnumerable<TValue>, IAsyncEnumerator<TValue>, IAsyncDisposable

Represents a concrete implementation of Fibers that processes items from a generator and yields results asynchronously.

Type Parameters

TSource

The type of the source items processed by the fiber.

TValue

The type of the result value produced by each task.

Inheritance

object

Fibers

Fibers<TSource, TValue>

Implements

IAsyncEnumerable<TValue>

IAsyncEnumerator<TValue>

IAsyncDisposable

Inherited Members

Fibers.NIL

Fibers.Result_Default

Fibers.Result_MustNotBeReached

Fibers.needLock_runningTasks

Fibers.sync_runningTasks

Fibers.taskSource

Fibers.State

Fibers.b_concurrency

Fibers.Concurrency

Fibers.IsFailed

Fibers.IsCompleted

Fibers.AsTask()

Fibers.GetAwaiter()

Fibers.b_errorHandler

Fibers.SetErrorHandler(Func<Exception, Fibers, Fibers.ErrorReason, Fibers.ErrorHandlingPolicy>)

Fibers.For<TResult>(int, int, int, int, Func<int, Task<TResult>>)

Fibers.ForEach<TSource, TResult>(int, IEnumerable<TSource>, Func<TSource, Task<TResult>>)

Extension Methods

DeferExtensions.Defer<T>(T, Action<T>)

DeferExtensions.Defer<T, TState>(T, TState, Action<T, TState>)

Constructors

Fibers(int, IEnumerator<(TSource source, Func<TSource, Task<TValue>> factory)>)

Initializes a new instance of the Fibers<TSource, TValue> class.

Properties

IsRunning

Gets a value indicating whether the fiber is actively processing tasks.

Methods

Start()

Starts the execution of the fiber. If the fiber is already running, it returns the existing active task.

Stop()

Stops the execution of the fiber and waits for currently running background tasks to complete.