Class RetainingMultiReaderBuffer<T>

Inheritance
object
RetainingMultiReaderBuffer<T>
DistinctRetainingMultiReaderBuffer<T>
Inherited Members
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public class RetainingMultiReaderBuffer<T>
Type Parameters
Name Description
T

Constructors

| Edit this page View Source

RetainingMultiReaderBuffer(long, long, ICursors)

Declaration
public RetainingMultiReaderBuffer(long initialSize, long maxSize, ICursors cursors)
Parameters
Type Name Description
long initialSize
long maxSize
ICursors cursors

Fields

| Edit this page View Source

Cursors

TBD

Declaration
protected readonly ICursors Cursors
Field Value
Type Description
ICursors

Properties

| Edit this page View Source

AvailableData

Declaration
public long AvailableData { get; }
Property Value
Type Description
long
| Edit this page View Source

Buffer

Declaration
protected T[] Buffer { get; }
Property Value
Type Description
T[]
| Edit this page View Source

CapacityLeft

The maximum number of elements the buffer can still take.

Declaration
public long CapacityLeft { get; }
Property Value
Type Description
long
| Edit this page View Source

IsEmpty

Declaration
public bool IsEmpty { get; }
Property Value
Type Description
bool
| Edit this page View Source

Length

The number of elements currently in the buffer.

Declaration
public long Length { get; }
Property Value
Type Description
long

Methods

| Edit this page View Source

Count(ICursor)

Returns the number of elements that the buffer currently contains for the given cursor.

Declaration
public long Count(ICursor cursor)
Parameters
Type Name Description
ICursor cursor

TBD
Returns
Type Description
long

TBD
| Edit this page View Source

InitCursor(ICursor)

Declaration
public void InitCursor(ICursor cursor)
Parameters
Type Name Description
ICursor cursor
| Edit this page View Source

OnCursorRemoved(ICursor)

Declaration
public void OnCursorRemoved(ICursor cursor)
Parameters
Type Name Description
ICursor cursor
| Edit this page View Source

Read(ICursor)

Declaration
public T Read(ICursor cursor)
Parameters
Type Name Description
ICursor cursor
Returns
Type Description
T
| Edit this page View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
string

TBD
Overrides
| Edit this page View Source

Write(T)

Declaration
public virtual bool Write(T value)
Parameters
Type Name Description
T value
Returns
Type Description
bool

Extension Methods