Buffer(T).OnPush Method (T, IDetachedContext(T))

BufferTOnPush Method (T, IDetachedContextT)

TBD

Namespace: Akka.Streams.Implementation.Fusing
Assembly: Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)

Syntax

Copy

public override IUpstreamDirective OnPush(
	T element,
	IDetachedContext<T> context
)

abstract OnPush : 
        element : 'T * 
        context : IDetachedContext<'T> -> IUpstreamDirective 
override OnPush : 
        element : 'T * 
        context : IDetachedContext<'T> -> IUpstreamDirective

Parameters

element: Type: T
TBD
context: Type: Akka.Streams.StageIDetachedContextT
TBD

Return Value

Type: IUpstreamDirective
TBD

Reference

BufferT Class

OnPush Overload

Akka.Streams.Implementation.Fusing Namespace