Prajna


BufferListStream<'T>

Constructors

ConstructorDescription
new(bls, offset)
Signature: (bls:BufferListStream<'T> * offset:int64) -> BufferListStream<'T>
new(bls)
Signature: bls:BufferListStream<'T> -> BufferListStream<'T>
new(bls, offset, count)
Signature: (bls:BufferListStream<'T> * offset:int64 * count:int64) -> BufferListStream<'T>
new(buf, index, count)
Signature: (buf:'T [] * index:int * count:int) -> BufferListStream<'T>
new()
Signature: unit -> BufferListStream<'T>
new(size)
Signature: size:int -> BufferListStream<'T>
new(bufSize, doNotUseDefault)
Signature: (bufSize:int * doNotUseDefault:bool) -> BufferListStream<'T>

Instance members

Instance memberDescription
Capacity64()
Signature: unit -> int64
Capacity64()
Signature: unit -> unit
DefaultBufferSize()
Signature: unit -> int
DefaultBufferSize()
Signature: unit -> unit
GetBuffer(arr, offset, count)
Signature: (arr:byte [] * offset:int64 * count:int64) -> byte []
GetNewNoDefault()
Signature: unit -> BufferListStream<'T>
Modifiers: abstract
GetNewWriteBuffer()
Signature: unit -> unit -> RBufPart<'T>
GetNewWriteBuffer()
Signature: unit -> unit
NumBuf
Signature: int
ReadArr(buf)
Signature: (buf:'TD []) -> int
ReadArr(buf, offset, count)
Signature: (buf:'TD [] * offset:int * count:int) -> int
ReadArrT(buf, offset, count)
Signature: (buf:Array * offset:int * count:int) -> int
ReadOne()
Signature: unit -> bool * 'T
SealAndGetNextWriteBuffer()
Signature: unit -> RefCntBuf<'T> * int * int
WriteArr(buf)
Signature: (buf:'TS []) -> unit
WriteArr(buf, offset, count)
Signature: (buf:'TS [] * offset:int * count:int) -> unit
WriteArrAlign(buf, offset, count, align)
Signature: (buf:'TS [] * offset:int * count:int * align:int) -> unit
WriteArrT(buf, offset, count)
Signature: (buf:Array * offset:int * count:int) -> unit
WriteOne(b)
Signature: b:'T -> unit

Static members

Static memberDescription
DumpStreamsInUse()
Signature: unit -> unit
InitFunc(e)
Signature: e:RefCntBuf<'T> -> unit
InitSharedPool()
Signature: unit -> unit
Fork me on GitHub