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

Declaration

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

Property Value

Type	Description
FlowShape<TElement, IEnumerable<TElement>>

Overrides

Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.FlowShape<TElement, System.Collections.Generic.IEnumerable<TElement>>, Akka.NotUsed>.Shape

Methods

CreateLogic(Attributes)

Declaration

protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)

Parameters

Type	Name	Description
Attributes	inheritedAttributes

Returns

Type	Description
GraphStageLogic

Overrides

Akka.Streams.Stage.GraphStage<Akka.Streams.FlowShape<TElement, System.Collections.Generic.IEnumerable<TElement>>>.CreateLogic(Akka.Streams.Attributes)

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)