Class AccumulateWhileUnchanged<TElement, TProperty>

Accumulates elements of type TElement while extracted property of type TProperty remains unchanged, emits an accumulated sequence when the property changes

Inheritance

object

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>

GraphStage<FlowShape<TElement, IEnumerable<TElement>>>

AccumulateWhileUnchanged<TElement, TProperty>

Implements

IGraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>

IGraph<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>

IGraph<FlowShape<TElement, IEnumerable<TElement>>>

Inherited Members

GraphStage<FlowShape<TElement, IEnumerable<TElement>>>.CreateLogicAndMaterializedValue(Attributes)

GraphStage<FlowShape<TElement, IEnumerable<TElement>>>.CreateLogic(Attributes)

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.InitialAttributes

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.Shape

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.WithAttributes(Attributes)

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.Module

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.AddAttributes(Attributes)

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.Named(string)

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.Async()

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 class AccumulateWhileUnchanged<TElement, TProperty> : GraphStage<FlowShape<TElement, IEnumerable<TElement>>>, IGraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>, IGraph<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>, IGraph<FlowShape<TElement, IEnumerable<TElement>>>

Type Parameters

Name	Description
TElement	type of accumulated elements
TProperty	type of the observed property

Constructors

AccumulateWhileUnchanged(Func<TElement, TProperty>)

Declaration

public AccumulateWhileUnchanged(Func<TElement, TProperty> propertyExtractor)

Parameters

Type	Name	Description
Func<TElement, TProperty>	propertyExtractor	a function to extract the observed element property

Properties

In

Declaration

public Inlet<TElement> In { get; }

Property Value

Type	Description
Inlet<TElement>

Out

Declaration

public Outlet<IEnumerable<TElement>> Out { get; }

Property Value

Type	Description
Outlet<IEnumerable<TElement>>

Shape

TBD

Declaration

public override FlowShape<TElement, IEnumerable<TElement>> Shape { get; }

Property Value

Type	Description
FlowShape<TElement, IEnumerable<TElement>>

Overrides

GraphStageWithMaterializedValue<FlowShape<TElement, IEnumerable<TElement>>, NotUsed>.Shape

Methods

CreateLogic(Attributes)

TBD

Declaration

protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)

Parameters

Type	Name	Description
Attributes	inheritedAttributes	TBD

Returns

Type	Description
GraphStageLogic	TBD

Overrides

GraphStage<FlowShape<TElement, IEnumerable<TElement>>>.CreateLogic(Attributes)

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)