Class OutputBunch<T>

TBD

Inheritance

Object

OutputBunch<T>

Inherited Members

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Streams.Implementation

Assembly: Akka.Streams.dll

Syntax

public class OutputBunch<T>

Type Parameters

Name	Description
T	TBD

Constructors

OutputBunch(Int32, IActorRef, IPump)

TBD

Declaration

public OutputBunch(int outputCount, IActorRef impl, IPump pump)

Parameters

Type	Name	Description
Int32	outputCount	TBD
IActorRef	impl	TBD
IPump	pump	TBD

Fields

AllOfMarkedOutputs

Will only transfer an element when all marked outputs have demand, and will complete as soon as any of the marked outputs have canceled.

Declaration

public readonly TransferState AllOfMarkedOutputs

Field Value

Type	Description
TransferState

AnyOfMarkedOutputs

Will transfer an element when any of the marked outputs have demand, and will complete when all of the marked outputs have canceled.

Declaration

public readonly TransferState AnyOfMarkedOutputs

Field Value

Type	Description
TransferState

SubReceive

TBD

Declaration

public readonly SubReceive SubReceive

Field Value

Type	Description
SubReceive

Methods

Cancel(Exception)

TBD

Declaration

public void Cancel(Exception e)

Parameters

Type	Name	Description
Exception	e	TBD

Complete()

TBD

Declaration

public void Complete()

Complete(Int32)

TBD

Declaration

public void Complete(int output)

Parameters

Type	Name	Description
Int32	output	TBD

DemandAvailableFor(Int32)

TBD

Declaration

public TransferState DemandAvailableFor(int id)

Parameters

Type	Name	Description
Int32	id	TBD

Returns

Type	Description
TransferState	TBD

DemandOrCancelAvailableFor(Int32)

TBD

Declaration

public TransferState DemandOrCancelAvailableFor(int id)

Parameters

Type	Name	Description
Int32	id	TBD

Returns

Type	Description
TransferState	TBD

Enqueue(Int32, T)

TBD

Declaration

public void Enqueue(int id, T element)

Parameters

Type	Name	Description
Int32	id	TBD
T	element	TBD

EnqueueAndPrefer(T, Int32)

TBD

Declaration

public void EnqueueAndPrefer(T element, int preferred)

Parameters

Type	Name	Description
T	element	TBD
Int32	preferred	TBD

EnqueueAndYield(T)

TBD

Declaration

public void EnqueueAndYield(T element)

Parameters

Type	Name	Description
T	element	TBD

EnqueueMarked(T)

TBD

Declaration

public void EnqueueMarked(T element)

Parameters

Type	Name	Description
T	element	TBD

Error(Int32, Exception)

TBD

Declaration

public void Error(int output, Exception e)

Parameters

Type	Name	Description
Int32	output	TBD
Exception	e	TBD

IdToEnqueue()

TBD

Declaration

public int IdToEnqueue()

Returns

Type	Description
Int32	TBD

Exceptions

Type	Condition
ArgumentException	TBD

IdToEnqueueAndYield()

TBD

Declaration

public int IdToEnqueueAndYield()

Returns

Type	Description
Int32	TBD

IsCancelled(Int32)

TBD

Declaration

public bool IsCancelled(int output)

Parameters

Type	Name	Description
Int32	output	TBD

Returns

Type	Description
Boolean	TBD

IsCompleted(Int32)

TBD

Declaration

public bool IsCompleted(int output)

Parameters

Type	Name	Description
Int32	output	TBD

Returns

Type	Description
Boolean	TBD

IsErrored(Int32)

TBD

Declaration

public bool IsErrored(int output)

Parameters

Type	Name	Description
Int32	output	TBD

Returns

Type	Description
Boolean	TBD

IsPending(Int32)

TBD

Declaration

public bool IsPending(int output)

Parameters

Type	Name	Description
Int32	output	TBD

Returns

Type	Description
Boolean	TBD

MarkAllOutputs()

TBD

Declaration

public void MarkAllOutputs()

MarkOutput(Int32)

TBD

Declaration

public void MarkOutput(int output)

Parameters

Type	Name	Description
Int32	output	TBD

OnCancel(Int32)

TBD

Declaration

public void OnCancel(int output)

Parameters

Type	Name	Description
Int32	output	TBD

UnmarkAllOutputs()

TBD

Declaration

public void UnmarkAllOutputs()

UnmarkCancelledOutputs(Boolean)

TBD

Declaration

public void UnmarkCancelledOutputs(bool enabled)

Parameters

Type	Name	Description
Boolean	enabled	TBD

UnmarkOutput(Int32)

TBD

Declaration

public void UnmarkOutput(int output)

Parameters

Type	Name	Description
Int32	output	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)