Class InputBunch

TBD

Inheritance

object

InputBunch

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 abstract class InputBunch

Constructors

| Edit this page View Source

InputBunch(int, int, IPump)

TBD

Declaration

protected InputBunch(int inputCount, int bufferSize, IPump pump)

Parameters

Type	Name	Description
int	inputCount	TBD
int	bufferSize	TBD
IPump	pump	TBD

Fields

| Edit this page View Source

AllOfMarkedInputs

TBD

Declaration

public readonly TransferState AllOfMarkedInputs

Field Value

Type	Description
TransferState

| Edit this page View Source

AnyOfMarkedInputs

TBD

Declaration

public readonly TransferState AnyOfMarkedInputs

Field Value

Type	Description
TransferState

| Edit this page View Source

SubReceive

TBD

Declaration

public readonly SubReceive SubReceive

Field Value

Type	Description
SubReceive

Properties

| Edit this page View Source

IsAllCompleted

TBD

Declaration

public bool IsAllCompleted { get; }

Property Value

Type	Description
bool

| Edit this page View Source

LastDequeuedId

TBD

Declaration

protected int LastDequeuedId { get; }

Property Value

Type	Description
int

Methods

| Edit this page View Source

Cancel()

TBD

Declaration

public void Cancel()

| Edit this page View Source

Cancel(int)

TBD

Declaration

public void Cancel(int input)

Parameters

Type	Name	Description
int	input	TBD

| Edit this page View Source

Dequeue(int)

TBD

Declaration

public object Dequeue(int id)

Parameters

Type	Name	Description
int	id	TBD

Returns

Type	Description
object	TBD

Exceptions

Type	Condition
ArgumentException	TBD This exception is thrown when either dequeuing from an empty `id` or there are no pending inputs.

| Edit this page View Source

DequeueAndYield()

TBD

Declaration

public object DequeueAndYield()

Returns

Type	Description
object	TBD

| Edit this page View Source

DequeueAndYield(int)

TBD

Declaration

public object DequeueAndYield(int id)

Parameters

Type	Name	Description
int	id	TBD

Returns

Type	Description
object	TBD

| Edit this page View Source

DequeuePreferring(int)

TBD

Declaration

public object DequeuePreferring(int preferred)

Parameters

Type	Name	Description
int	preferred	TBD

Returns

Type	Description
object	TBD

| Edit this page View Source

IdToDequeue()

TBD

Declaration

public int IdToDequeue()

Returns

Type	Description
int	TBD

Exceptions

Type	Condition
IllegalStateException	This exception is thrown when dequeuing with no input. TBD

| Edit this page View Source

InputsAvailableFor(int)

TBD

Declaration

public TransferState InputsAvailableFor(int id)

Parameters

Type	Name	Description
int	id	TBD

Returns

Type	Description
TransferState	TBD

| Edit this page View Source

InputsOrCompleteAvailableFor(int)

TBD

Declaration

public TransferState InputsOrCompleteAvailableFor(int id)

Parameters

Type	Name	Description
int	id	TBD

Returns

Type	Description
TransferState	TBD

| Edit this page View Source

IsCancelled(int)

TBD

Declaration

public bool IsCancelled(int index)

Parameters

Type	Name	Description
int	index	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

IsCompleted(int)

TBD

Declaration

public bool IsCompleted(int index)

Parameters

Type	Name	Description
int	index	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

IsDepleted(int)

TBD

Declaration

public bool IsDepleted(int index)

Parameters

Type	Name	Description
int	index	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

IsPending(int)

TBD

Declaration

public bool IsPending(int index)

Parameters

Type	Name	Description
int	index	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

MarkAllInputs()

TBD

Declaration

public void MarkAllInputs()

| Edit this page View Source

MarkInput(int)

TBD

Declaration

public void MarkInput(int input)

Parameters

Type	Name	Description
int	input	TBD

| Edit this page View Source

OnCompleteWhenNoInput()

TBD

Declaration

public virtual void OnCompleteWhenNoInput()

| Edit this page View Source

OnDepleted(int)

TBD

Declaration

public virtual void OnDepleted(int input)

Parameters

Type	Name	Description
int	input	TBD

| Edit this page View Source

OnError(int, Exception)

TBD

Declaration

public abstract void OnError(int id, Exception cause)

Parameters

Type	Name	Description
int	id	TBD
Exception	cause	TBD

| Edit this page View Source

UnmarkAllInputs()

TBD

Declaration

public void UnmarkAllInputs()

| Edit this page View Source

UnmarkInput(int)

TBD

Declaration

public void UnmarkInput(int input)

Parameters

Type	Name	Description
int	input	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)