suspend fun asyncStreamWriter(bufferSize: Int = AsyncRingBufferChunked.DEFAULT_MAX_SIZE, name: String? = null, lazy: Boolean = false, process: suspend (out: AsyncOutputStream) -> Unit): AsyncInputStream

Creates a an AsyncInputStream from a process function that writes to a AsyncOutputStream.

buffered

fun AsyncStream.buffered(blockSize: Int = 2048, blocksToRead: Int = 16): AsyncStream

bufferedInput

fun AsyncInputStream.bufferedInput(bufferSize: Int = 8192): AsyncBufferedInputStream

combine

fun List<AsyncInputStreamWithLength>.combine(): AsyncInputStreamWithLength

consume

inline suspend fun AsyncInputStream.consume(autoclose: Boolean = true, temp: ByteArray = ByteArray(0x10000), block: (data: ByteArray, offset: Int, size: Int) -> Unit)

copyTo

fun SyncInputStream.copyTo(target: SyncOutputStream)

suspend fun AsyncInputStream.copyTo(target: AsyncOutputStream, chunkSize: Int = 8 * 1024 * 1024): Long

DequeSyncStream

fun DequeSyncStream(): SyncStream

FillSyncStream

fun FillSyncStream(fillByte: Int = 0, length: Long = Long.MAX_VALUE): SyncStream

getAvailable

suspend fun AsyncInputStreamWithLength.getAvailable(): Long

getWrittenRange

inline fun AsyncStream.getWrittenRange(callback: () -> Unit): LongRange

hasAvailable

suspend fun AsyncInputStreamWithLength.hasAvailable(): Boolean

keepPosition

inline fun <T> AsyncStream.keepPosition(callback: () -> T): T

inline fun <T> SyncStream.keepPosition(callback: () -> T): T

markable

fun SyncInputStream.markable(): MarkableSyncInputStream

MemoryAsyncStream

fun MemoryAsyncStream(data: ByteArrayBuilder): AsyncStream

fun MemoryAsyncStream(initialCapacity: Int = 4096): AsyncStream

MemorySyncStream

fun MemorySyncStream(data: ByteArrayBuilder): SyncStream

fun MemorySyncStream(data: ByteArray = EMPTY_BYTE_ARRAY): SyncStream

MemorySyncStreamToByteArray

inline fun MemorySyncStreamToByteArray(initialCapacity: Int = 4096, callback: SyncStream.() -> Unit): ByteArray

openAsync

fun String.openAsync(): AsyncStream

fun ByteArray.openAsync(mode: String = "r"): AsyncStream

fun String.openAsync(charset: Charset = UTF8): AsyncStream

openFastStream

fun ByteArray.openFastStream(offset: Int = 0): FastByteArrayInputStream

openSync

fun String.openSync(): SyncStream

fun ByteArray.openSync(mode: String = "r"): SyncStream

fun String.openSync(charset: Charset = UTF8): SyncStream

openUse

inline suspend fun <T> AsyncInputOpenable.openUse(block: (AsyncInputStream) -> T): T

plus

operator fun AsyncInputStreamWithLength.plus(other: AsyncInputStreamWithLength): AsyncInputStreamWithLength

read

suspend fun AsyncInputStream.read(data: ByteArray): Int

suspend fun AsyncInputStream.read(data: UByteArray): Int

fun SyncInputStream.read(data: ByteArray): Int

fun SyncInputStream.read(data: UByteArray): Int

readAll

suspend fun AsyncInputStream.readAll(): ByteArray

fun SyncStream.readAll(): ByteArray

readAllAsFastStream

suspend fun AsyncStream.readAllAsFastStream(offset: Int = 0): FastByteArrayInputStream

readAvailable

suspend fun AsyncInputStream.readAvailable(): ByteArray

fun SyncStream.readAvailable(): ByteArray

readBufferedLine

suspend fun AsyncBufferedInputStream.readBufferedLine(limit: Int = 4096): String

suspend fun AsyncBufferedInputStream.readBufferedLine(limit: Int = 4096, charset: Charset = UTF8): String

readBytes

fun SyncInputStream.readBytes(len: Int): ByteArray

suspend fun AsyncStreamBase.readBytes(position: Long, count: Int): ByteArray

readBytesExact

suspend fun AsyncInputStream.readBytesExact(len: Int): ByteArray

fun SyncInputStream.readBytesExact(len: Int): ByteArray

readBytesUpTo

suspend fun AsyncInputStream.readBytesUpTo(len: Int): ByteArray

suspend fun AsyncInputStream.readBytesUpTo(out: ByteArray, offset: Int, len: Int): Int

readBytesUpToCopy

suspend fun AsyncInputStream.readBytesUpToCopy(out: ByteArray): ByteArray

readBytesUpToFirst

suspend fun AsyncInputStream.readBytesUpToFirst(len: Int): ByteArray

readCharArray

suspend fun AsyncInputStream.readCharArray(count: Int, endian: Endian): CharArray

readCharArrayBE

suspend fun AsyncInputStream.readCharArrayBE(count: Int): CharArray

fun SyncInputStream.readCharArrayBE(count: Int): CharArray

readCharArrayLE

suspend fun AsyncInputStream.readCharArrayLE(count: Int): CharArray

fun SyncInputStream.readCharArrayLE(count: Int): CharArray

readChunks

inline suspend fun AsyncInputStream.readChunks(temp: ByteArray = ByteArray(1024), block: (bytes: ByteArray, len: Int) -> Unit)

readDoubleArray

suspend fun AsyncInputStream.readDoubleArray(count: Int, endian: Endian): DoubleArray

readDoubleArrayBE

suspend fun AsyncInputStream.readDoubleArrayBE(count: Int): DoubleArray

fun SyncInputStream.readDoubleArrayBE(count: Int): DoubleArray

readDoubleArrayLE

suspend fun AsyncInputStream.readDoubleArrayLE(count: Int): DoubleArray

fun SyncInputStream.readDoubleArrayLE(count: Int): DoubleArray

readExact

suspend fun AsyncInputStream.readExact(buffer: ByteArray, offset: Int, len: Int)

fun SyncInputStream.readExact(out: ByteArray, offset: Int, len: Int)

readExactTo

fun SyncInputStream.readExactTo(buffer: ByteArray, offset: Int = 0, length: Int = buffer.size - offset): Int

readF32

suspend fun AsyncInputStream.readF32(endian: Endian): Float

readF32BE

suspend fun AsyncInputStream.readF32BE(): Float

fun SyncInputStream.readF32BE(): Float

readF32LE

suspend fun AsyncInputStream.readF32LE(): Float

fun SyncInputStream.readF32LE(): Float

readF64

suspend fun AsyncInputStream.readF64(endian: Endian): Double

readF64BE

suspend fun AsyncInputStream.readF64BE(): Double

fun SyncInputStream.readF64BE(): Double

readF64LE

suspend fun AsyncInputStream.readF64LE(): Double

fun SyncInputStream.readF64LE(): Double

readFastByteArrayInputStream

fun SyncStream.readFastByteArrayInputStream(length: Int): FastByteArrayInputStream

readFloatArray

suspend fun AsyncInputStream.readFloatArray(count: Int, endian: Endian): FloatArray

readFloatArrayBE

suspend fun AsyncInputStream.readFloatArrayBE(count: Int): FloatArray

fun SyncInputStream.readFloatArrayBE(count: Int): FloatArray

readFloatArrayLE

suspend fun AsyncInputStream.readFloatArrayLE(count: Int): FloatArray

fun SyncInputStream.readFloatArrayLE(count: Int): FloatArray

readIntArray

suspend fun AsyncInputStream.readIntArray(count: Int, endian: Endian): IntArray

readIntArrayBE

suspend fun AsyncInputStream.readIntArrayBE(count: Int): IntArray

fun SyncInputStream.readIntArrayBE(count: Int): IntArray

readIntArrayLE

suspend fun AsyncInputStream.readIntArrayLE(count: Int): IntArray

fun SyncInputStream.readIntArrayLE(count: Int): IntArray

readLine

suspend fun AsyncInputStream.readLine(eol: Char = '\n', charset: Charset = UTF8, limit: Int = Int.MAX_VALUE, initialCapacity: Int = 4096, includeEnd: Boolean = false): String

readLongArray

suspend fun AsyncInputStream.readLongArray(count: Int, endian: Endian): LongArray

readLongArrayBE

suspend fun AsyncInputStream.readLongArrayBE(count: Int): LongArray

fun SyncInputStream.readLongArrayBE(count: Int): LongArray

readLongArrayLE

suspend fun AsyncInputStream.readLongArrayLE(count: Int): LongArray

fun SyncInputStream.readLongArrayLE(count: Int): LongArray

suspend fun AsyncInputStream.readS16(endian: Endian): Int

readS16BE

suspend fun AsyncInputStream.readS16BE(): Int

fun SyncInputStream.readS16BE(): Int

readS16LE

suspend fun AsyncInputStream.readS16LE(): Int

fun SyncInputStream.readS16LE(): Int

suspend fun AsyncInputStream.readS24(endian: Endian): Int

readS24BE

suspend fun AsyncInputStream.readS24BE(): Int

fun SyncInputStream.readS24BE(): Int

readS24LE

suspend fun AsyncInputStream.readS24LE(): Int

fun SyncInputStream.readS24LE(): Int

suspend fun AsyncInputStream.readS32(endian: Endian): Int

readS32BE

suspend fun AsyncInputStream.readS32BE(): Int

fun SyncInputStream.readS32BE(): Int

readS32LE

suspend fun AsyncInputStream.readS32LE(): Int

fun SyncInputStream.readS32LE(): Int

suspend fun AsyncInputStream.readS64(endian: Endian): Long

readS64BE

suspend fun AsyncInputStream.readS64BE(): Long

fun SyncInputStream.readS64BE(): Long

readS64LE

suspend fun AsyncInputStream.readS64LE(): Long

fun SyncInputStream.readS64LE(): Long

suspend fun AsyncInputStream.readS8(): Int

fun SyncInputStream.readS8(): Int

readS_VL

fun SyncInputStream.readS_VL(): Int

readShortArray

suspend fun AsyncInputStream.readShortArray(count: Int, endian: Endian): ShortArray

readShortArrayBE

suspend fun AsyncInputStream.readShortArrayBE(count: Int): ShortArray

fun SyncInputStream.readShortArrayBE(count: Int): ShortArray

readShortArrayLE

suspend fun AsyncInputStream.readShortArrayLE(count: Int): ShortArray

fun SyncInputStream.readShortArrayLE(count: Int): ShortArray

readSlice

suspend fun AsyncStream.readSlice(length: Long): AsyncStream

fun SyncStream.readSlice(length: Long): SyncStream

readStream

suspend fun AsyncStream.readStream(length: Int): AsyncStream

suspend fun AsyncStream.readStream(length: Long): AsyncStream

fun SyncStream.readStream(length: Int): SyncStream

fun SyncStream.readStream(length: Long): SyncStream

readString

fun SyncInputStream.readString(len: Int): String

suspend fun AsyncInputStream.readString(len: Int, charset: Charset = UTF8): String

fun SyncInputStream.readString(len: Int, charset: Charset = UTF8): String

readStringVL

fun SyncStream.readStringVL(): String

fun SyncStream.readStringVL(charset: Charset = UTF8): String

readStringz

suspend fun AsyncInputStream.readStringz(charset: Charset = UTF8): String

fun SyncInputStream.readStringz(len: Int): String

suspend fun AsyncInputStream.readStringz(len: Int, charset: Charset = UTF8): String

fun SyncInputStream.readStringz(charset: Charset = UTF8, zero: Byte = 0): String

fun SyncInputStream.readStringz(len: Int, charset: Charset = UTF8): String

readU16

suspend fun AsyncInputStream.readU16(endian: Endian): Int

readU16BE

suspend fun AsyncInputStream.readU16BE(): Int

fun SyncInputStream.readU16BE(): Int

readU16LE

suspend fun AsyncInputStream.readU16LE(): Int

fun SyncInputStream.readU16LE(): Int

readU24

suspend fun AsyncInputStream.readU24(endian: Endian): Int

readU24BE

suspend fun AsyncInputStream.readU24BE(): Int

fun SyncInputStream.readU24BE(): Int

readU24LE

suspend fun AsyncInputStream.readU24LE(): Int

fun SyncInputStream.readU24LE(): Int

readU32

suspend fun AsyncInputStream.readU32(endian: Endian): Long

readU32BE

suspend fun AsyncInputStream.readU32BE(): Long

fun SyncInputStream.readU32BE(): Long

readU32LE

suspend fun AsyncInputStream.readU32LE(): Long

fun SyncInputStream.readU32LE(): Long

readU8

suspend fun AsyncInputStream.readU8(): Int

fun SyncInputStream.readU8(): Int

readU_VL

fun SyncInputStream.readU_VL(): Int

readUByteArray

suspend fun AsyncInputStream.readUByteArray(count: Int): UByteArray

fun SyncInputStream.readUByteArray(count: Int): UByteArray

readUntil

suspend fun AsyncInputStream.readUntil(endByte: Byte, limit: Int = Int.MAX_VALUE, initialCapacity: Int = 4096, includeEnd: Boolean = false, temp: ByteArray = ByteArray(1)): ByteArray

sequenceSyncStream