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

| Improve this Doc 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`2

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

| Improve this Doc View Source

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

Context-preserving variant of Grouped<TIn, TOut, TMat>(Flow<TIn, TOut, TMat>, Int32) 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
Int32	n

Returns

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

Type Parameters

Name	Description
TIn
TCtx
TOut
TMat

| Improve this Doc 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

| Improve this Doc View Source

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

Context-preserving variant of SelectAsync<T, TIn, TOut, TMat>(Flow<T, TIn, TMat>, Int32, 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
Int32	parallelism
Func<TOut, Task<TOut2>>	fn

Returns

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

Type Parameters

Name	Description
TIn
TCtx
TOut
TOut2
TMat

| Improve this Doc 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

| Improve this Doc 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

| Improve this Doc View Source

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

Context-preserving variant of Sliding<TIn, TOut, TMat>(Flow<TIn, TOut, TMat>, Int32, Int32) 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
Int32	n
Int32	step

Returns

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

Type Parameters

Name	Description
TIn
TCtx
TOut
TMat

| Improve this Doc 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

| Improve this Doc View Source

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

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, Boolean>	predicate

Returns

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

Type Parameters

Name	Description
TIn
TCtx
TOut
TMat

| Improve this Doc View Source

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

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

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, Boolean>	predicate

Returns

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

Type Parameters

Name	Description
TIn
TCtx
TOut
TMat