Class PipeExtensions

Namespace

MarymoorStudios.Core.Rpc

Assembly

MarymoorStudios.Core.Rpc.dll

Provides convenience extensions for Pipe<T> and its related classes.

public static class PipeExtensions

Inheritance

object

PipeExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

AsPipeReader<T>(ICollection<T>, Exception?)

Returns a PipeReader<T> over a finite collection.

public static PipeReader<T> AsPipeReader<T>(this ICollection<T> collection, Exception? error = null)

Parameters

collection ICollection<T>

The collection.

error Exception

An optional error to terminate the sequence with.

Returns

PipeReader<T>

Type Parameters

T

GetAsyncEnumerator<T>(PipeReader<T>)

Returns an enumerator that iterates asynchronously through the PipeReader<T>.

public static PipeExtensions.PipeReaderEnumerator<T> GetAsyncEnumerator<T>(this PipeReader<T> reader)

Parameters

reader PipeReader<T>

Returns

PipeExtensions.PipeReaderEnumerator<T>

Type Parameters

T