LanguageExt.Streaming ► SourceT ► Extensions

Contents

SourceTExtensions

Delay (TimeSpan duration)
Delay (Duration duration)

SourceTExtensions

As <M, A> (this K<SourceT<M>, A> ma)
AsSourceT <M, A> (this Channel<A> items)
AsSourceM <M, A> (this Channel<K<M, A>> items)
AsSourceT <M, A> (this Source<A> items)
AsSourceM <M, A> (this Source<K<M, A>> items)
AsSourceT <M, A> (this IEnumerable<A> items)
AsSourceM <M, A> (this IEnumerable<K<M, A>> items)
AsSourceT <M, A> (this IObservable<A> items)
AsSourceM <M, A> (this IObservable<K<M, A>> items)
AsSourceT <M, A> (this IAsyncEnumerable<A> items)
AsSourceM <M, A> (this IAsyncEnumerable<K<M, A>> items)
Bind <M, A, B> (this IO<A> ma, Func<A, SourceT<M, B>> f)
Bind <M, A, B> (this Pure<A> ma, Func<A, SourceT<M, B>> f)
Bind <M, A, B> (this K<M, A> ma, Func<A, SourceT<M, B>> f)
SelectMany <M, A, B, C> (this K<M, A> ma, Func<A, SourceT<M, B>> bind, Func<A, B, C> project)
SelectMany <M, A, B, C> (this IO<A> ma, Func<A, SourceT<M, B>> bind, Func<A, B, C> project)
SelectMany <M, A, B, C> (this Pure<A> ma, Func<A, SourceT<M, B>> bind, Func<A, B, C> project)
SomeSource <M, A> (this IAsyncEnumerable<OptionT<M, A>> stream)
SomeSource <M, A> (this IAsyncEnumerable<Option<A>> stream)
SomeSource <M, A> (this IEnumerable<OptionT<M, A>> stream)
SomeSource <M, A> (this IEnumerable<Option<A>> stream)
RightSource <M, L, A> (this IAsyncEnumerable<EitherT<L, M, A>> stream)
RightSource <M, L, A> (this IAsyncEnumerable<Either<L, A>> stream)
RightSource <M, L, A> (this IEnumerable<EitherT<L, M, A>> stream)
RightSource <M, L, A> (this IEnumerable<Either<L, A>> stream)
LeftSource <M, L, A> (this IAsyncEnumerable<EitherT<L, M, A>> stream)
LeftSource <M, L, A> (this IAsyncEnumerable<Either<L, A>> stream)
LeftSource <M, L, A> (this IEnumerable<EitherT<L, M, A>> stream)
LeftSource <M, L, A> (this IEnumerable<Either<L, A>> stream)
SuccSource <M, A> (this IAsyncEnumerable<FinT<M, A>> stream)
SuccSource <M, A> (this IAsyncEnumerable<Fin<A>> stream)
SuccSource <M, A> (this IEnumerable<FinT<M, A>> stream)
SuccSource <M, A> (this IEnumerable<Fin<A>> stream)
FailSource <M, A> (this IAsyncEnumerable<FinT<M, A>> stream)
FailSource <M, A> (this IAsyncEnumerable<Fin<A>> stream)
FailSource <M, A> (this IEnumerable<FinT<M, A>> stream)
FailSource <M, A> (this IEnumerable<Fin<A>> stream)
SuccSource <M, L, A> (this IAsyncEnumerable<ValidationT<L, M, A>> stream)
SuccSource <M, L, A> (this IAsyncEnumerable<Validation<L, A>> stream)
SuccSource <M, L, A> (this IEnumerable<ValidationT<L, M, A>> stream)
SuccSource <M, L, A> (this IEnumerable<Validation<L, A>> stream)
FailSource <M, L, A> (this IAsyncEnumerable<ValidationT<L, M, A>> stream)
FailsStream <M, L, A> (this IAsyncEnumerable<Validation<L, A>> stream)
FailSource <M, L, A> (this IEnumerable<ValidationT<L, M, A>> stream)
FailSource <M, L, A> (this IEnumerable<Validation<L, A>> stream)

SourceTExtensions

Iter ()
CollectWhile (Func<(Seq<A> Items, A Item), bool> predicate)
CollectUntil (Func<(Seq<A> Items, A Item), bool> predicate)
Collect ()

class SourceTExtensions Source #

Methods

method SourceT<M, A> Delay (TimeSpan duration) Source #

Delay the yielding of values by the specified duration

Parameters

param	duration	Duration to delay the yielding of values for
returns

method SourceT<M, A> Delay (Duration duration) Source #

Delay the yielding of values by the specified duration

Parameters

param	duration	Duration to delay the yielding of values for
returns

class SourceTExtensions Source #

Methods

method SourceT<M, A> As <M, A> (this K<SourceT<M>, A> ma) Source #

where M : MonadIO<M>

Downcast

method SourceT<M, A> AsSourceT <M, A> (this Channel<A> items) Source #

where M : MonadIO<M>, Fallible<M>

method SourceT<M, A> AsSourceM <M, A> (this Channel<K<M, A>> items) Source #

where M : MonadIO<M>, Fallible<M>

method SourceT<M, A> AsSourceT <M, A> (this Source<A> items) Source #

where M : MonadIO<M>

method SourceT<M, A> AsSourceM <M, A> (this Source<K<M, A>> items) Source #

where M : MonadIO<M>

method SourceT<M, A> AsSourceT <M, A> (this IEnumerable<A> items) Source #

where M : MonadIO<M>

method SourceT<M, A> AsSourceM <M, A> (this IEnumerable<K<M, A>> items) Source #

where M : MonadIO<M>

method SourceT<M, A> AsSourceT <M, A> (this IObservable<A> items) Source #

where M : MonadIO<M>

method SourceT<M, A> AsSourceM <M, A> (this IObservable<K<M, A>> items) Source #

where M : MonadIO<M>

method SourceT<M, A> AsSourceT <M, A> (this IAsyncEnumerable<A> items) Source #

where M : MonadIO<M>

method SourceT<M, A> AsSourceM <M, A> (this IAsyncEnumerable<K<M, A>> items) Source #

where M : MonadIO<M>

method SourceT<M, B> Bind <M, A, B> (this IO<A> ma, Func<A, SourceT<M, B>> f) Source #

where M : MonadIO<M>

Monad bind

method SourceT<M, B> Bind <M, A, B> (this Pure<A> ma, Func<A, SourceT<M, B>> f) Source #

where M : MonadIO<M>

Monad bind

method SourceT<M, B> Bind <M, A, B> (this K<M, A> ma, Func<A, SourceT<M, B>> f) Source #

where M : MonadIO<M>

Monad bind

method SourceT<M, C> SelectMany <M, A, B, C> (this K<M, A> ma, Func<A, SourceT<M, B>> bind, Func<A, B, C> project) Source #

where M : MonadIO<M>

Monad bind

method SourceT<M, C> SelectMany <M, A, B, C> (this IO<A> ma, Func<A, SourceT<M, B>> bind, Func<A, B, C> project) Source #

where M : MonadIO<M>

Monad bind

method SourceT<M, C> SelectMany <M, A, B, C> (this Pure<A> ma, Func<A, SourceT<M, B>> bind, Func<A, B, C> project) Source #

where M : MonadIO<M>

Monad bind

method SourceT<M, A> SomeSource <M, A> (this IAsyncEnumerable<OptionT<M, A>> stream) Source #

where M : MonadIO<M>

Access the Some values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of optional values
returns	Stream of values

method SourceT<M, A> SomeSource <M, A> (this IAsyncEnumerable<Option<A>> stream) Source #

where M : MonadIO<M>

Access the Some values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of optional values
returns	Stream of values

method SourceT<M, A> SomeSource <M, A> (this IEnumerable<OptionT<M, A>> stream) Source #

where M : MonadIO<M>

Access the Some values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of optional values
returns	Stream of values

method SourceT<M, A> SomeSource <M, A> (this IEnumerable<Option<A>> stream) Source #

where M : MonadIO<M>

Access the Some values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of optional values
returns	Stream of values

method SourceT<M, A> RightSource <M, L, A> (this IAsyncEnumerable<EitherT<L, M, A>> stream) Source #

where M : MonadIO<M>

Access the Right values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> RightSource <M, L, A> (this IAsyncEnumerable<Either<L, A>> stream) Source #

where M : MonadIO<M>

Access the Right values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> RightSource <M, L, A> (this IEnumerable<EitherT<L, M, A>> stream) Source #

where M : MonadIO<M>

Access the Right values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> RightSource <M, L, A> (this IEnumerable<Either<L, A>> stream) Source #

where M : MonadIO<M>

Access the Right values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, L> LeftSource <M, L, A> (this IAsyncEnumerable<EitherT<L, M, A>> stream) Source #

where M : MonadIO<M>

Access the Left values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, L> LeftSource <M, L, A> (this IAsyncEnumerable<Either<L, A>> stream) Source #

where M : MonadIO<M>

Access the Left values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, L> LeftSource <M, L, A> (this IEnumerable<EitherT<L, M, A>> stream) Source #

where M : MonadIO<M>

Access the Left values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, L> LeftSource <M, L, A> (this IEnumerable<Either<L, A>> stream) Source #

where M : MonadIO<M>

Access the Succ values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> SuccSource <M, A> (this IAsyncEnumerable<FinT<M, A>> stream) Source #

where M : MonadIO<M>

Access the Succ values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> SuccSource <M, A> (this IAsyncEnumerable<Fin<A>> stream) Source #

where M : MonadIO<M>

Access the Succ values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> SuccSource <M, A> (this IEnumerable<FinT<M, A>> stream) Source #

where M : MonadIO<M>

Access the Succ values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> SuccSource <M, A> (this IEnumerable<Fin<A>> stream) Source #

where M : MonadIO<M>

Access the Succ values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, Error> FailSource <M, A> (this IAsyncEnumerable<FinT<M, A>> stream) Source #

where M : MonadIO<M>

Access the Fail values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, Error> FailSource <M, A> (this IAsyncEnumerable<Fin<A>> stream) Source #

where M : MonadIO<M>

Access the Fail values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, Error> FailSource <M, A> (this IEnumerable<FinT<M, A>> stream) Source #

where M : MonadIO<M>

Access the Fail values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, Error> FailSource <M, A> (this IEnumerable<Fin<A>> stream) Source #

where M : MonadIO<M>

Access the Fail values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> SuccSource <M, L, A> (this IAsyncEnumerable<ValidationT<L, M, A>> stream) Source #

where L : Monoid<L>

where M : MonadIO<M>

Access the Succ values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> SuccSource <M, L, A> (this IAsyncEnumerable<Validation<L, A>> stream) Source #

where L : Monoid<L>

where M : MonadIO<M>

Access the Succ values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> SuccSource <M, L, A> (this IEnumerable<ValidationT<L, M, A>> stream) Source #

where L : Monoid<L>

where M : MonadIO<M>

Access the Succ values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, A> SuccSource <M, L, A> (this IEnumerable<Validation<L, A>> stream) Source #

where L : Monoid<L>

where M : MonadIO<M>

Access the Succ values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, L> FailSource <M, L, A> (this IAsyncEnumerable<ValidationT<L, M, A>> stream) Source #

where L : Monoid<L>

where M : MonadIO<M>

Access the Fail values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, L> FailsStream <M, L, A> (this IAsyncEnumerable<Validation<L, A>> stream) Source #

where L : Monoid<L>

where M : MonadIO<M>

Access the Fail values from the asynchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, L> FailSource <M, L, A> (this IEnumerable<ValidationT<L, M, A>> stream) Source #

where L : Monoid<L>

where M : MonadIO<M>

Access the Fail values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

method SourceT<M, L> FailSource <M, L, A> (this IEnumerable<Validation<L, A>> stream) Source #

where L : Monoid<L>

where M : MonadIO<M>

Access the Fail values from the synchronous stream

Parameters

type	M	Transformer monad
type	A	Bound value type
param	stream	Stream of values
returns	Stream of values

class SourceTExtensions Source #

Methods

method K<M, Unit> Iter () Source #

Force iteration of the stream, yielding a unit M structure.

The expectation is that the stream uses IO for side effects, so this makes them happen.

method K<M, Seq<A>> CollectWhile (Func<(Seq<A> Items, A Item), bool> predicate) Source #

Collect all the values into a Seq while the predicate holds.

Parameters

returns

method K<M, Seq<A>> CollectUntil (Func<(Seq<A> Items, A Item), bool> predicate) Source #

Collect all the values into a Seq while the predicate holds.

Parameters

returns

method K<M, Seq<A>> Collect () Source #

Force iteration of the stream and collect all the values into a Seq.