korlibs-io-stream/korlibs.io.stream/AsyncStream

AsyncStream

class AsyncStream(val base: AsyncStreamBase, var position: Long = 0, val queue: Boolean = false) : Extra, AsyncInputStream, AsyncInputStreamWithLength, AsyncOutputStream, AsyncPositionLengthStream, AsyncCloseable

Constructors

Link copied to clipboard
constructor(base: AsyncStreamBase, position: Long = 0, queue: Boolean = false)

Properties

Link copied to clipboard
Link copied to clipboard
open override var extra: ExtraType
Link copied to clipboard
var position: Long
Link copied to clipboard
val queue: Boolean

Functions

Link copied to clipboard
fun AsyncStream.buffered(blockSize: Int = 2048, blocksToRead: Int = 16): AsyncStream
Link copied to clipboard
Link copied to clipboard
open suspend override fun close()
Link copied to clipboard
inline suspend fun AsyncInputStream.consume(autoclose: Boolean = true, temp: ByteArray = ByteArray(0x10000), block: (data: ByteArray, offset: Int, size: Int) -> Unit)
Link copied to clipboard
suspend fun AsyncInputStream.copyTo(target: AsyncOutputStream, chunkSize: Int = 8 * 1024 * 1024): Long
Link copied to clipboard
Link copied to clipboard
open suspend fun eof(): Boolean
Link copied to clipboard
open suspend fun getAvailable(): Long
Link copied to clipboard
Link copied to clipboard
open suspend override fun getLength(): Long
Link copied to clipboard
open suspend override fun getPosition(): Long
Link copied to clipboard
inline fun AsyncStream.getWrittenRange(callback: () -> Unit): LongRange
Link copied to clipboard
open suspend fun hasAvailable(): Boolean
Link copied to clipboard
Link copied to clipboard
open suspend override fun hasLength(): Boolean
Link copied to clipboard
inline fun <T> AsyncStream.keepPosition(callback: () -> T): T
Link copied to clipboard
Link copied to clipboard
open suspend fun read(): Int
open suspend override fun read(buffer: ByteArray, offset: Int = 0, len: Int = buffer.size - offset): Int
Link copied to clipboard
suspend fun AsyncInputStream.read(data: ByteArray): Int
suspend fun AsyncInputStream.read(data: UByteArray): Int
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readBytesUpTo(len: Int): ByteArray
suspend fun AsyncInputStream.readBytesUpTo(out: ByteArray, offset: Int, len: Int): Int
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readCharArray(count: Int, endian: Endian): CharArray
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
inline suspend fun AsyncInputStream.readChunks(temp: ByteArray = ByteArray(1024), block: (bytes: ByteArray, len: Int) -> Unit)
Link copied to clipboard
suspend fun AsyncInputStream.readDoubleArray(count: Int, endian: Endian): DoubleArray
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readExact(buffer: ByteArray, offset: Int, len: Int)
Link copied to clipboard
suspend fun AsyncInputStream.readF32(endian: Endian): Float
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readF64(endian: Endian): Double
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readFloatArray(count: Int, endian: Endian): FloatArray
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readIntArray(count: Int, endian: Endian): IntArray
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readLine(eol: Char = '\n', charset: Charset = UTF8, limit: Int = Int.MAX_VALUE, initialCapacity: Int = 4096, includeEnd: Boolean = false): String
Link copied to clipboard
suspend fun AsyncInputStream.readLongArray(count: Int, endian: Endian): LongArray
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readS16(endian: Endian): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS16BE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS16LE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS24(endian: Endian): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS24BE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS24LE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS32(endian: Endian): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS32BE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS32LE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readS64(endian: Endian): Long
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readS8(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readShortArray(count: Int, endian: Endian): ShortArray
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncStream.readSlice(length: Long): AsyncStream
Link copied to clipboard
suspend fun AsyncStream.readStream(length: Int): AsyncStream
suspend fun AsyncStream.readStream(length: Long): AsyncStream
Link copied to clipboard
suspend fun AsyncInputStream.readString(len: Int, charset: Charset = UTF8): String
Link copied to clipboard
suspend fun AsyncInputStream.readStringz(charset: Charset = UTF8): String
suspend fun AsyncInputStream.readStringz(len: Int, charset: Charset = UTF8): String
Link copied to clipboard
suspend fun AsyncInputStream.readU16(endian: Endian): Int
Link copied to clipboard
suspend fun AsyncInputStream.readU16BE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readU16LE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readU24(endian: Endian): Int
Link copied to clipboard
suspend fun AsyncInputStream.readU24BE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readU24LE(): Int
Link copied to clipboard
suspend fun AsyncInputStream.readU32(endian: Endian): Long
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readU8(): Int
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncInputStream.readUntil(endByte: Byte, limit: Int = Int.MAX_VALUE, initialCapacity: Int = 4096, includeEnd: Boolean = false, temp: ByteArray = ByteArray(1)): ByteArray
Link copied to clipboard
open suspend override fun setLength(value: Long)
Link copied to clipboard
open suspend override fun setPosition(value: Long)
Link copied to clipboard
suspend fun size(): Long
Link copied to clipboard
suspend fun AsyncInputStream.skip(count: Int)
fun AsyncStream.skip(count: Int): AsyncStream
Link copied to clipboard
fun AsyncStream.skipToAlign(alignment: Int)
fun AsyncStream.skipToAlign(alignment: Int, offset: Int)
Link copied to clipboard
suspend fun AsyncStream.slice(range: IntRange, closeParent: Boolean = false): AsyncStream
suspend fun AsyncStream.slice(range: LongRange, closeParent: Boolean = false): AsyncStream
Link copied to clipboard
suspend fun AsyncStream.sliceHere(closeParent: Boolean = false): AsyncStream
Link copied to clipboard
suspend fun AsyncStream.sliceStart(start: Long = 0, closeParent: Boolean = false): AsyncStream
Link copied to clipboard
suspend fun AsyncStream.sliceWithBounds(start: Long, end: Long, closeParent: Boolean = false): AsyncStream
Link copied to clipboard
suspend fun AsyncStream.sliceWithSize(start: Int, length: Int, closeParent: Boolean = false): AsyncStream
suspend fun AsyncStream.sliceWithSize(start: Long, length: Long, closeParent: Boolean = false): AsyncStream
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun toString(): String
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncStream.truncate()
Link copied to clipboard
Link copied to clipboard
open suspend fun write(byte: Int)
open suspend override fun write(buffer: ByteArray, offset: Int = 0, len: Int = buffer.size - offset)
Link copied to clipboard
suspend fun AsyncOutputStream.write16BE(v: Int)
Link copied to clipboard
suspend fun AsyncOutputStream.write16LE(v: Int)
Link copied to clipboard
suspend fun AsyncOutputStream.write24BE(v: Int)
Link copied to clipboard
suspend fun AsyncOutputStream.write24LE(v: Int)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncOutputStream.write64BE(v: Long)
Link copied to clipboard
suspend fun AsyncOutputStream.write64LE(v: Long)
Link copied to clipboard
suspend fun AsyncOutputStream.write8(v: Int)
Link copied to clipboard
suspend fun AsyncOutputStream.writeBytes(data: ByteArray)
suspend fun AsyncOutputStream.writeBytes(data: ByteArray, position: Int, length: Int)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun AsyncOutputStream.writeString(string: String, charset: Charset = UTF8)
Link copied to clipboard
suspend fun AsyncOutputStream.writeStringVL(str: String, charset: Charset = UTF8): AsyncOutputStream
Link copied to clipboard
suspend fun AsyncOutputStream.writeStringz(str: String, charset: Charset = UTF8)
suspend fun AsyncOutputStream.writeStringz(str: String, len: Int, charset: Charset = UTF8)
Link copied to clipboard
inline suspend fun AsyncOutputStream.writeSync(hintSize: Int = 4096, callback: SyncStream.() -> Unit)
Link copied to clipboard
inline suspend fun AsyncOutputStream.writeTempBytes(size: Int, block: ByteArray.() -> Unit)
Link copied to clipboard
suspend fun AsyncStream.writeToAlign(alignment: Int, value: Int = 0)
Link copied to clipboard
suspend fun AsyncOutputStream.writeU_VL(value: Int)
Generated by Dokka
© 2026 Copyright