Class FlowWithContextOperations

Inheritance

object

FlowWithContextOperations

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 FlowWithContextOperations

Methods

| Edit this page View Source

Collect<TIn, TCtx, TOut, TOut2, TMat>(FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>, Func<TOut, TOut2>)

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, TOut2, TCtx, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TOut2
TMat

| Edit this page View Source

Grouped<TIn, TCtx, TOut, TMat>(FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>, int)

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, IReadOnlyList<TOut>, IReadOnlyList<TCtx>, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TMat

| Edit this page View Source

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

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, TOut2, TCtx, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TOut2
TMat

| Edit this page View Source

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

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, TOut2, TCtx, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TOut2
TMat

| Edit this page View Source

SelectContext<TIn, TCtx, TOut, TCtx2, TMat>(FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>, Func<TCtx, TCtx2>)

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, TOut, TCtx2, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TCtx2
TMat

| Edit this page View Source

Select<TIn, TCtx, TOut, TOut2, TMat>(FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>, Func<TOut, TOut2>)

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, TOut2, TCtx, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TOut2
TMat

| Edit this page View Source

Sliding<TIn, TCtx, TOut, TMat>(FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>, int, int)

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, IReadOnlyList<TOut>, IReadOnlyList<TCtx>, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TMat

| Edit this page View Source

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

Context-preserving variant of StatefulSelectMany<T, TIn, TOut, TMat>(Flow<T, TIn, TMat>, Func<Func<TIn, IEnumerable<TOut>>>).

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, TOut2, TCtx, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TOut2
TMat

| Edit this page View Source

WhereNot<TIn, TCtx, TOut, TMat>(FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>, Func<TOut, bool>)

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TMat

| Edit this page View Source

Where<TIn, TCtx, TOut, TMat>(FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>, Func<TOut, bool>)

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

Declaration

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

Parameters

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

Returns

Type	Description
FlowWithContext<TIn, TCtx, TOut, TCtx, TMat>

Type Parameters

Name	Description
TIn
TCtx
TOut
TMat