Class BatchingInputBuffer

TBD

Inheritance
Object
BatchingInputBuffer
Inherited Members
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public abstract class BatchingInputBuffer

Constructors

| Improve this Doc View Source

BatchingInputBuffer(Int32, IPump)

TBD

Declaration
protected BatchingInputBuffer(int count, IPump pump)
Parameters
Type Name Description
Int32 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

| Improve this Doc View Source

Count

TBD

Declaration
public readonly int Count
Field Value
Type Description
Int32
| Improve this Doc View Source

Pump

TBD

Declaration
public readonly IPump Pump
Field Value
Type Description
IPump

Properties

| Improve this Doc View Source

AreInputsAvailable

TBD

Declaration
public bool AreInputsAvailable { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

AreInputsDepleted

TBD

Declaration
public bool AreInputsDepleted { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

IsClosed

TBD

Declaration
public bool IsClosed { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

IsOpen

TBD

Declaration
public bool IsOpen { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

NeedsInput

TBD

Declaration
public TransferState NeedsInput { get; }
Property Value
Type Description
TransferState
| Improve this Doc View Source

NeedsInputOrComplete

TBD

Declaration
public TransferState NeedsInputOrComplete { get; }
Property Value
Type Description
TransferState
| Improve this Doc View Source

SubReceive

TBD

Declaration
public virtual SubReceive SubReceive { get; }
Property Value
Type Description
SubReceive

Methods

| Improve this Doc View Source

Cancel()

TBD

Declaration
public virtual void Cancel()
| Improve this Doc View Source

Completed(Object)

TBD

Declaration
protected virtual bool Completed(object message)
Parameters
Type Name Description
Object message

TBD
Returns
Type Description
Boolean

TBD
Exceptions
Type Condition
IllegalStateException

TBD
| Improve this Doc View Source

DequeueInputElement()

TBD

Declaration
public virtual object DequeueInputElement()
Returns
Type Description
Object

TBD
| Improve this Doc View Source

EnqueueInputElement(Object)

TBD

Declaration
protected virtual void EnqueueInputElement(object element)
Parameters
Type Name Description
Object element

TBD
Exceptions
Type Condition
IllegalStateException

TBD
| Improve this Doc View Source

InputOnError(Exception)

TBD

Declaration
protected virtual void InputOnError(Exception e)
Parameters
Type Name Description
Exception e

TBD
| Improve this Doc View Source

OnComplete()

TBD

Declaration
protected virtual void OnComplete()
| Improve this Doc View Source

OnError(Exception)

TBD

Declaration
protected virtual void OnError(Exception e)
Parameters
Type Name Description
Exception e

TBD
| Improve this Doc View Source

OnSubscribe(ISubscription)

TBD

Declaration
protected virtual void OnSubscribe(ISubscription subscription)
Parameters
Type Name Description
Reactive.Streams.ISubscription subscription

TBD
Exceptions
Type Condition
ArgumentNullException

This exception is thrown when the specified subscription is undefined.
| Improve this Doc View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
String

TBD
Overrides
| Improve this Doc View Source

UpstreamRunning(Object)

TBD

Declaration
protected virtual bool UpstreamRunning(object message)
Parameters
Type Name Description
Object message

TBD
Returns
Type Description
Boolean

TBD
| Improve this Doc View Source

WaitingForUpstream(Object)

TBD

Declaration
protected virtual bool WaitingForUpstream(object message)
Parameters
Type Name Description
Object message

TBD
Returns
Type Description
Boolean

TBD

Extension Methods