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

| Improve this Doc View Source

RetainingMultiReaderBuffer(Int64, Int64, ICursors)

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

Fields

| Improve this Doc View Source

Cursors

TBD

Declaration
protected readonly ICursors Cursors
Field Value
Type Description
ICursors

Properties

| Improve this Doc View Source

AvailableData

Declaration
public long AvailableData { get; }
Property Value
Type Description
Int64
| Improve this Doc View Source

Buffer

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

CapacityLeft

The maximum number of elements the buffer can still take.

Declaration
public long CapacityLeft { get; }
Property Value
Type Description
Int64
| Improve this Doc View Source

IsEmpty

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

Length

The number of elements currently in the buffer.

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

Methods

| Improve this Doc 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
Int64

TBD
| Improve this Doc View Source

InitCursor(ICursor)

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

OnCursorRemoved(ICursor)

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

Read(ICursor)

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

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
String

TBD
Overrides
| Improve this Doc View Source

Write(T)

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

Extension Methods