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

| Improve this Doc View Source

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

Context-preserving variant of Akka.Streams.Implementation.Fusing.Collect`2

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

| Improve this Doc View Source

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

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

Returns

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

Type Parameters

Name	Description
TOut
TCtx
TMat

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

| Improve this Doc View Source

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

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

Returns

Type	Description
SourceWithContext<TOut2, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TOut2
TMat

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

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

| Improve this Doc View Source

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

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

Returns

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

Type Parameters

Name	Description
TOut
TCtx
TMat

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

| Improve this Doc View Source

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

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

Returns

Type	Description
SourceWithContext<TOut, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TMat

| Improve this Doc View Source

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

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

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

Returns

Type	Description
SourceWithContext<TOut, TCtx, TMat>

Type Parameters

Name	Description
TOut
TCtx
TMat