data class RetryFlowDelayConfig(val scheduleBase: Duration = 100.milliseconds, val scheduleFactor: Double = 2.0, val scheduleLimit: Duration = 5.minutes, val scheduleJitter: ClosedRange<Double> = 0.9..1.1)

TrixnityDsl

@DslMarker

@Target(allowedTargets = [AnnotationTarget.CLASS, AnnotationTarget.TYPEALIAS, AnnotationTarget.TYPE, AnnotationTarget.FUNCTION])

annotation class TrixnityDsl

TrixnityPrivateApi

annotation class TrixnityPrivateApi

Properties

BYTE_ARRAY_FLOW_CHUNK_SIZE

const val BYTE_ARRAY_FLOW_CHUNK_SIZE: Long

Functions

byteArrayFlowFromInputStream

fun byteArrayFlowFromInputStream(coroutineContext: CoroutineContext = ioContext, inputStreamFactory: suspend () -> InputStream): ByteArrayFlow

byteArrayFlowFromReadableStream

fun byteArrayFlowFromReadableStream(streamFactory: suspend () -> ReadableStream<Uint8Array<ArrayBuffer>>): ByteArrayFlow

byteArrayFlowFromSource

fun byteArrayFlowFromSource(coroutineContext: CoroutineContext = ioContext, sourceFactory: suspend () -> Source): Flow<ByteArray>

concurrentMutableList

fun <E> concurrentMutableList(): ConcurrentList<E>

concurrentMutableMap

fun <K, V> concurrentMutableMap(): ConcurrentMap<K, V>

concurrentMutableSet

fun <E> concurrentMutableSet(): ConcurrentSet<E>

concurrentOf

fun <R, W : R> concurrentOf(constructor: () -> W): Concurrent<R, W>

decodeUnpaddedBase64Bytes

fun String.decodeUnpaddedBase64Bytes(): ByteArray

encodeUnpaddedBase64

fun ByteArray.encodeUnpaddedBase64(): String

nextString

fun Random.nextString(length: Int, alphabet: List<Char> = defaultAlphabet): String

Returns a string using an alphabet between a-z, A-Z and 0-9.

readByteArrayFlow

fun FileSystem.readByteArrayFlow(path: Path, coroutineContext: CoroutineContext = ioContext): ByteArrayFlow?

retry

suspend fun <T> retry(scheduleBase: Duration = RetryFlowDelayConfig.default.scheduleBase, scheduleFactor: Double = RetryFlowDelayConfig.default.scheduleFactor, scheduleLimit: Duration = RetryFlowDelayConfig.default.scheduleLimit, scheduleJitter: ClosedRange<Double> = RetryFlowDelayConfig.default.scheduleJitter, onError: suspend (error: Throwable, delay: Duration) -> Unit = { _, _ -> }, block: suspend () -> T): T

retryFlow

fun <T> retryFlow(delayConfig: Flow<RetryFlowDelayConfig> = flowOf(RetryFlowDelayConfig()), onError: suspend (error: Throwable, delay: Duration) -> Unit = { _, _ -> }, block: suspend FlowCollector<T>.() -> Unit): Flow<T>

fun <T> retryFlow(scheduleBase: Duration = RetryFlowDelayConfig.default.scheduleBase, scheduleFactor: Double = RetryFlowDelayConfig.default.scheduleFactor, scheduleLimit: Duration = RetryFlowDelayConfig.default.scheduleLimit, scheduleJitter: ClosedRange<Double> = RetryFlowDelayConfig.default.scheduleJitter, onError: suspend (error: Throwable, delay: Duration) -> Unit = { _, _ -> }, block: suspend FlowCollector<T>.() -> Unit): Flow<T>

retryLoop

suspend fun retryLoop(delayConfig: Flow<RetryFlowDelayConfig> = flowOf(RetryFlowDelayConfig()), onError: suspend (error: Throwable, delay: Duration) -> Unit = { _, _ -> }, block: suspend () -> Unit)

suspend fun retryLoop(scheduleBase: Duration = RetryFlowDelayConfig.default.scheduleBase, scheduleFactor: Double = RetryFlowDelayConfig.default.scheduleFactor, scheduleLimit: Duration = RetryFlowDelayConfig.default.scheduleLimit, scheduleJitter: ClosedRange<Double> = RetryFlowDelayConfig.default.scheduleJitter, onError: suspend (error: Throwable, delay: Duration) -> Unit = { _, _ -> }, block: suspend () -> Unit)

toByteArray

suspend fun ByteArrayFlow.toByteArray(): ByteArray

suspend fun ByteArrayFlow.toByteArray(maxSize: Long): ByteArray?

Returns null, when maxSize exceeded.

toByteArrayFlow

fun ByteReadChannel.toByteArrayFlow(): ByteArrayFlow

The returned Flow can only be collected once!

fun ByteArray.toByteArrayFlow(): ByteArrayFlow

fun ByteBuffer.toByteArrayFlow(): ByteArrayFlow

toByteReadChannel

suspend fun ByteArrayFlow.toByteReadChannel(): ByteReadChannel

withReentrantLock

suspend fun <T> Mutex.withReentrantLock(block: suspend () -> T): T

write

suspend fun BufferedSink.write(content: ByteArrayFlow, coroutineContext: CoroutineContext = ioContext)

suspend fun FileSystem.write(path: Path, content: ByteArrayFlow, coroutineContext: CoroutineContext = ioContext)

suspend fun OutputStream.write(content: ByteArrayFlow, coroutineContext: CoroutineContext = ioContext)

suspend fun WritableStream<Uint8Array<ArrayBuffer>>.write(content: ByteArrayFlow)

writeTo

suspend fun ByteArrayFlow.writeTo(byteWriteChannel: ByteWriteChannel)

suspend fun ByteArrayFlow.writeTo(sink: BufferedSink, coroutineContext: CoroutineContext = ioContext)

suspend fun ByteArrayFlow.writeTo(outputStream: OutputStream, coroutineContext: CoroutineContext = ioContext)

suspend fun ByteArrayFlow.writeTo(writableStream: WritableStream<Uint8Array<ArrayBuffer>>)