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

| Edit this page View Source

OutputBunch(int, IActorRef, IPump)

TBD

Declaration

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

Parameters

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

Fields

| Edit this page View Source

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

| Edit this page View Source

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

| Edit this page View Source

SubReceive

TBD

Declaration

public readonly SubReceive SubReceive

Field Value

Type	Description
SubReceive

Methods

| Edit this page View Source

Cancel(Exception)

TBD

Declaration

public void Cancel(Exception e)

Parameters

Type	Name	Description
Exception	e	TBD

| Edit this page View Source

Complete()

TBD

Declaration

public void Complete()

| Edit this page View Source

Complete(int)

TBD

Declaration

public void Complete(int output)

Parameters

Type	Name	Description
int	output	TBD

| Edit this page View Source

DemandAvailableFor(int)

TBD

Declaration

public TransferState DemandAvailableFor(int id)

Parameters

Type	Name	Description
int	id	TBD

Returns

Type	Description
TransferState	TBD

| Edit this page View Source

DemandOrCancelAvailableFor(int)

TBD

Declaration

public TransferState DemandOrCancelAvailableFor(int id)

Parameters

Type	Name	Description
int	id	TBD

Returns

Type	Description
TransferState	TBD

| Edit this page View Source

Enqueue(int, T)

TBD

Declaration

public void Enqueue(int id, T element)

Parameters

Type	Name	Description
int	id	TBD
T	element	TBD

| Edit this page View Source

EnqueueAndPrefer(T, int)

TBD

Declaration

public void EnqueueAndPrefer(T element, int preferred)

Parameters

Type	Name	Description
T	element	TBD
int	preferred	TBD

| Edit this page View Source

EnqueueAndYield(T)

TBD

Declaration

public void EnqueueAndYield(T element)

Parameters

Type	Name	Description
T	element	TBD

| Edit this page View Source

EnqueueMarked(T)

TBD

Declaration

public void EnqueueMarked(T element)

Parameters

Type	Name	Description
T	element	TBD

| Edit this page View Source

Error(int, Exception)

TBD

Declaration

public void Error(int output, Exception e)

Parameters

Type	Name	Description
int	output	TBD
Exception	e	TBD

| Edit this page View Source

IdToEnqueue()

TBD

Declaration

public int IdToEnqueue()

Returns

Type	Description
int	TBD

Exceptions

Type	Condition
ArgumentException	TBD

| Edit this page View Source

IdToEnqueueAndYield()

TBD

Declaration

public int IdToEnqueueAndYield()

Returns

Type	Description
int	TBD

| Edit this page View Source

IsCancelled(int)

TBD

Declaration

public bool IsCancelled(int output)

Parameters

Type	Name	Description
int	output	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

IsCompleted(int)

TBD

Declaration

public bool IsCompleted(int output)

Parameters

Type	Name	Description
int	output	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

IsErrored(int)

TBD

Declaration

public bool IsErrored(int output)

Parameters

Type	Name	Description
int	output	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

IsPending(int)

TBD

Declaration

public bool IsPending(int output)

Parameters

Type	Name	Description
int	output	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

MarkAllOutputs()

TBD

Declaration

public void MarkAllOutputs()

| Edit this page View Source

MarkOutput(int)

TBD

Declaration

public void MarkOutput(int output)

Parameters

Type	Name	Description
int	output	TBD

| Edit this page View Source

OnCancel(int)

TBD

Declaration

public void OnCancel(int output)

Parameters

Type	Name	Description
int	output	TBD

| Edit this page View Source

UnmarkAllOutputs()

TBD

Declaration

public void UnmarkAllOutputs()

| Edit this page View Source

UnmarkCancelledOutputs(bool)

TBD

Declaration

public void UnmarkCancelledOutputs(bool enabled)

Parameters

Type	Name	Description
bool	enabled	TBD

| Edit this page View Source

UnmarkOutput(int)

TBD

Declaration

public void UnmarkOutput(int output)

Parameters

Type	Name	Description
int	output	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)