Class SourceWithContextOperations

Inheritance

object

SourceWithContextOperations

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Streams.Dsl

Assembly: Akka.Streams.dll

Syntax

public static class SourceWithContextOperations

Methods

| Edit this page View Source

Collect<TOut, TCtx, TOut2, TMat>(SourceWithContext<TOut, TCtx, TMat>, Func<TOut, TOut2>)

Context-preserving variant of Akka.Streams.Implementation.Fusing.Collect<TIn, TOut>

Declaration

public static SourceWithContext<TOut2, TCtx, TMat> Collect<TOut, TCtx, TOut2, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, Func<TOut, TOut2> fn) where TOut2 : class

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
Func<TOut, TOut2>	fn

Returns

Type	Description
SourceWithContext<TOut2, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TOut2
TMat

| Edit this page View Source

Grouped<TOut, TCtx, TMat>(SourceWithContext<TOut, TCtx, TMat>, int)

Context-preserving variant of Grouped<TOut, TMat>(Source<TOut, TMat>, int) Each output group will be associated with a Seq of corresponding context elements.

Declaration

public static SourceWithContext<IReadOnlyList<TOut>, IReadOnlyList<TCtx>, TMat> Grouped<TOut, TCtx, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, int n)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
int	n

Returns

Type	Description
SourceWithContext<IReadOnlyList<TOut>, IReadOnlyList<TCtx>, TMat>

Type Parameters

Name	Description
TOut
TCtx
TMat

| Edit this page View Source

SelectAsync<TOut, TCtx, TOut2, TMat>(SourceWithContext<TOut, TCtx, TMat>, int, Func<TOut, Task<TOut2>>)

Context-preserving variant of SelectAsync<TIn, TOut, TMat>(Source<TIn, TMat>, int, Func<TIn, Task<TOut>>)

Declaration

public static SourceWithContext<TOut2, TCtx, TMat> SelectAsync<TOut, TCtx, TOut2, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, int parallelism, Func<TOut, Task<TOut2>> fn)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
int	parallelism
Func<TOut, Task<TOut2>>	fn

Returns

Type	Description
SourceWithContext<TOut2, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TOut2
TMat

| Edit this page View Source

SelectConcat<TOut, TCtx, TOut2, TMat>(SourceWithContext<TOut, TCtx, TMat>, Func<TOut, IEnumerable<TOut2>>)

Context-preserving variant of SelectMany<TOut1, TOut2, TMat>(Source<TOut1, TMat>, Func<TOut1, IEnumerable<TOut2>>). The context of the input element will be associated with each of the output elements calculated from this input element.

Declaration

public static SourceWithContext<TOut2, TCtx, TMat> SelectConcat<TOut, TCtx, TOut2, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, Func<TOut, IEnumerable<TOut2>> fn)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
Func<TOut, IEnumerable<TOut2>>	fn

Returns

Type	Description
SourceWithContext<TOut2, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TOut2
TMat

| Edit this page View Source

SelectContext<TOut, TCtx, TCtx2, TMat>(SourceWithContext<TOut, TCtx, TMat>, Func<TCtx, TCtx2>)

Apply the given function to each context element (leaving the data elements unchanged).

Declaration

public static SourceWithContext<TOut, TCtx2, TMat> SelectContext<TOut, TCtx, TCtx2, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, Func<TCtx, TCtx2> mapContext)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
Func<TCtx, TCtx2>	mapContext

Returns

Type	Description
SourceWithContext<TOut, TCtx2, TMat>

Type Parameters

Name	Description
TOut
TCtx
TCtx2
TMat

| Edit this page View Source

Select<TOut, TCtx, TOut2, TMat>(SourceWithContext<TOut, TCtx, TMat>, Func<TOut, TOut2>)

Context-preserving variant of Select<TIn, TOut, TMat>(Source<TIn, TMat>, Func<TIn, TOut>)

Declaration

public static SourceWithContext<TOut2, TCtx, TMat> Select<TOut, TCtx, TOut2, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, Func<TOut, TOut2> fn)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
Func<TOut, TOut2>	fn

Returns

Type	Description
SourceWithContext<TOut2, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TOut2
TMat

| Edit this page View Source

Sliding<TOut, TCtx, TMat>(SourceWithContext<TOut, TCtx, TMat>, int, int)

Context-preserving variant of Sliding<TOut, TMat>(Source<TOut, TMat>, int, int) Each output group will be associated with a Seq of corresponding context elements.

Declaration

public static SourceWithContext<IReadOnlyList<TOut>, IReadOnlyList<TCtx>, TMat> Sliding<TOut, TCtx, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, int n, int step = 1)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
int	n
int	step

Returns

Type	Description
SourceWithContext<IReadOnlyList<TOut>, IReadOnlyList<TCtx>, TMat>

Type Parameters

Name	Description
TOut
TCtx
TMat

| Edit this page View Source

StatefulSelectConcat<TOut, TCtx, TOut2, TMat>(SourceWithContext<TOut, TCtx, TMat>, Func<Func<TOut, IEnumerable<TOut2>>>)

Context-preserving variant of StatefulSelectMany<TOut1, TOut2, TMat>(Source<TOut1, TMat>, Func<Func<TOut1, IEnumerable<TOut2>>>).

Declaration

public static SourceWithContext<TOut2, TCtx, TMat> StatefulSelectConcat<TOut, TCtx, TOut2, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, Func<Func<TOut, IEnumerable<TOut2>>> fn)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
Func<Func<TOut, IEnumerable<TOut2>>>	fn

Returns

Type	Description
SourceWithContext<TOut2, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TOut2
TMat

| Edit this page View Source

WhereNot<TOut, TCtx, TMat>(SourceWithContext<TOut, TCtx, TMat>, Func<TOut, bool>)

Context-preserving variant of Grouped<TOut, TMat>(Source<TOut, TMat>, int)

Declaration

public static SourceWithContext<TOut, TCtx, TMat> WhereNot<TOut, TCtx, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, Func<TOut, bool> predicate)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
Func<TOut, bool>	predicate

Returns

Type	Description
SourceWithContext<TOut, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TMat

| Edit this page View Source

Where<TOut, TCtx, TMat>(SourceWithContext<TOut, TCtx, TMat>, Func<TOut, bool>)

Context-preserving variant of Where<TOut, TMat>(Source<TOut, TMat>, Predicate<TOut>)

Declaration

public static SourceWithContext<TOut, TCtx, TMat> Where<TOut, TCtx, TMat>(this SourceWithContext<TOut, TCtx, TMat> flow, Func<TOut, bool> predicate)

Parameters

Type	Name	Description
SourceWithContext<TOut, TCtx, TMat>	flow
Func<TOut, bool>	predicate

Returns

Type	Description
SourceWithContext<TOut, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TMat