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

| Improve this Doc View Source

InputBunch(Int32, Int32, IPump)

TBD

Declaration

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

Parameters

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

Fields

| Improve this Doc View Source

AllOfMarkedInputs

TBD

Declaration

public readonly TransferState AllOfMarkedInputs

Field Value

Type	Description
TransferState

| Improve this Doc View Source

AnyOfMarkedInputs

TBD

Declaration

public readonly TransferState AnyOfMarkedInputs

Field Value

Type	Description
TransferState

| Improve this Doc View Source

SubReceive

TBD

Declaration

public readonly SubReceive SubReceive

Field Value

Type	Description
SubReceive

Properties

| Improve this Doc View Source

IsAllCompleted

TBD

Declaration

public bool IsAllCompleted { get; }

Property Value

Type	Description
Boolean

| Improve this Doc View Source

LastDequeuedId

TBD

Declaration

protected int LastDequeuedId { get; }

Property Value

Type	Description
Int32

Methods

| Improve this Doc View Source

Cancel()

TBD

Declaration

public void Cancel()

| Improve this Doc View Source

Cancel(Int32)

TBD

Declaration

public void Cancel(int input)

Parameters

Type	Name	Description
Int32	input	TBD

| Improve this Doc View Source

Dequeue(Int32)

TBD

Declaration

public object Dequeue(int id)

Parameters

Type	Name	Description
Int32	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.

| Improve this Doc View Source

DequeueAndYield()

TBD

Declaration

public object DequeueAndYield()

Returns

Type	Description
Object	TBD

| Improve this Doc View Source

DequeueAndYield(Int32)

TBD

Declaration

public object DequeueAndYield(int id)

Parameters

Type	Name	Description
Int32	id	TBD

Returns

Type	Description
Object	TBD

| Improve this Doc View Source

DequeuePreferring(Int32)

TBD

Declaration

public object DequeuePreferring(int preferred)

Parameters

Type	Name	Description
Int32	preferred	TBD

Returns

Type	Description
Object	TBD

| Improve this Doc View Source

IdToDequeue()

TBD

Declaration

public int IdToDequeue()

Returns

Type	Description
Int32	TBD

Exceptions

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

| Improve this Doc View Source

InputsAvailableFor(Int32)

TBD

Declaration

public TransferState InputsAvailableFor(int id)

Parameters

Type	Name	Description
Int32	id	TBD

Returns

Type	Description
TransferState	TBD

| Improve this Doc View Source

InputsOrCompleteAvailableFor(Int32)

TBD

Declaration

public TransferState InputsOrCompleteAvailableFor(int id)

Parameters

Type	Name	Description
Int32	id	TBD

Returns

Type	Description
TransferState	TBD

| Improve this Doc View Source

IsCancelled(Int32)

TBD

Declaration

public bool IsCancelled(int index)

Parameters

Type	Name	Description
Int32	index	TBD

Returns

Type	Description
Boolean	TBD

| Improve this Doc View Source

IsCompleted(Int32)

TBD

Declaration

public bool IsCompleted(int index)

Parameters

Type	Name	Description
Int32	index	TBD

Returns

Type	Description
Boolean	TBD

| Improve this Doc View Source

IsDepleted(Int32)

TBD

Declaration

public bool IsDepleted(int index)

Parameters

Type	Name	Description
Int32	index	TBD

Returns

Type	Description
Boolean	TBD

| Improve this Doc View Source

IsPending(Int32)

TBD

Declaration

public bool IsPending(int index)

Parameters

Type	Name	Description
Int32	index	TBD

Returns

Type	Description
Boolean	TBD

| Improve this Doc View Source

MarkAllInputs()

TBD

Declaration

public void MarkAllInputs()

| Improve this Doc View Source

MarkInput(Int32)

TBD

Declaration

public void MarkInput(int input)

Parameters

Type	Name	Description
Int32	input	TBD

| Improve this Doc View Source

OnCompleteWhenNoInput()

TBD

Declaration

public virtual void OnCompleteWhenNoInput()

| Improve this Doc View Source

OnDepleted(Int32)

TBD

Declaration

public virtual void OnDepleted(int input)

Parameters

Type	Name	Description
Int32	input	TBD

| Improve this Doc View Source

OnError(Int32, Exception)

TBD

Declaration

public abstract void OnError(int id, Exception cause)

Parameters

Type	Name	Description
Int32	id	TBD
Exception	cause	TBD

| Improve this Doc View Source

UnmarkAllInputs()

TBD

Declaration

public void UnmarkAllInputs()

| Improve this Doc View Source

UnmarkInput(Int32)

TBD

Declaration

public void UnmarkInput(int input)

Parameters

Type	Name	Description
Int32	input	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)