Class BatchingInputBuffer

TBD

Inheritance

object

BatchingInputBuffer

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

Namespace: Akka.Streams.Implementation

Assembly: Akka.Streams.dll

Syntax

public abstract class BatchingInputBuffer

Constructors

BatchingInputBuffer(int, IPump)

TBD

Declaration

protected BatchingInputBuffer(int count, IPump pump)

Parameters

Type	Name	Description
int	count	TBD
IPump	pump	TBD

Exceptions

Type	Condition
ArgumentException	This exception is thrown when the specified count is either less than or equal to zero or is not a power of two.

Fields

Count

TBD

Declaration

public readonly int Count

Field Value

Type	Description
int

Pump

TBD

Declaration

public readonly IPump Pump

Field Value

Type	Description
IPump

Properties

AreInputsAvailable

TBD

Declaration

public bool AreInputsAvailable { get; }

Property Value

Type	Description
bool

AreInputsDepleted

TBD

Declaration

public bool AreInputsDepleted { get; }

Property Value

Type	Description
bool

IsClosed

TBD

Declaration

public bool IsClosed { get; }

Property Value

Type	Description
bool

IsOpen

TBD

Declaration

public bool IsOpen { get; }

Property Value

Type	Description
bool

NeedsInput

TBD

Declaration

public TransferState NeedsInput { get; }

Property Value

Type	Description
TransferState

NeedsInputOrComplete

TBD

Declaration

public TransferState NeedsInputOrComplete { get; }

Property Value

Type	Description
TransferState

SubReceive

TBD

Declaration

public virtual SubReceive SubReceive { get; }

Property Value

Type	Description
SubReceive

Methods

Cancel()

TBD

Declaration

public virtual void Cancel()

Completed(object)

TBD

Declaration

protected virtual bool Completed(object message)

Parameters

Type	Name	Description
object	message	TBD

Returns

Type	Description
bool	TBD

Exceptions

Type	Condition
IllegalStateException	TBD

DequeueInputElement()

TBD

Declaration

public virtual object DequeueInputElement()

Returns

Type	Description
object	TBD

EnqueueInputElement(object)

TBD

Declaration

protected virtual void EnqueueInputElement(object element)

Parameters

Type	Name	Description
object	element	TBD

Exceptions

Type	Condition
IllegalStateException	TBD

InputOnError(Exception)

TBD

Declaration

protected virtual void InputOnError(Exception e)

Parameters

Type	Name	Description
Exception	e	TBD

OnComplete()

TBD

Declaration

protected virtual void OnComplete()

OnError(Exception)

TBD

Declaration

protected virtual void OnError(Exception e)

Parameters

Type	Name	Description
Exception	e	TBD

OnSubscribe(ISubscription)

TBD

Declaration

protected virtual void OnSubscribe(ISubscription subscription)

Parameters

Type	Name	Description
ISubscription	subscription	TBD

Exceptions

Type	Condition
ArgumentNullException	This exception is thrown when the specified subscription is undefined.

ToString()

TBD

Declaration

public override string ToString()

Returns

Type	Description
string	TBD

Overrides

object.ToString()

UpstreamRunning(object)

TBD

Declaration

protected virtual bool UpstreamRunning(object message)

Parameters

Type	Name	Description
object	message	TBD

Returns

Type	Description
bool	TBD

WaitingForUpstream(object)

TBD

Declaration

protected virtual bool WaitingForUpstream(object message)

Parameters

Type	Name	Description
object	message	TBD

Returns

Type	Description
bool	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)