component-model/uk.shusek.krwa.component/WasiPreview3

WasiPreview3

class WasiPreview3 : WasiPreview3CanonicalIntrinsics, AutoCloseable

Types

Builder

class Builder

Companion

object Companion

ExitException

class ExitException(statusCode: Int) : RuntimeException

Functions

acceptTcpConnection

fun acceptTcpConnection(handle: Long): WitResult<WitResource<*>, Any?>

fun acceptTcpConnection(stream: WitStream<*>): WitResult<WitResource<*>, Any?>

awaitFuture

suspend fun <T> awaitFuture(future: WitFuture<T>): T

awaitFutureValue

open suspend override fun awaitFutureValue(futureHandle: Long): Any?

awaitStreamReadable

open suspend override fun awaitStreamReadable(streamHandle: Long)

suspend fun awaitStreamReadable(stream: WitStream<*>)

awaitStreamWritable

open suspend override fun awaitStreamWritable(streamHandle: Long)

suspend fun awaitStreamWritable(stream: WitStream<*>)

byteStream

fun byteStream(bytes: ByteArray): WitStream<UByte>

fun byteStream(chunks: Flow<ByteArray>): WitStream<UByte>

cancel

fun cancel()

open override fun close()

completedFuture

fun completedFuture(value: Any?): WitFuture<Any?>

completedFutureHandle

open override fun completedFutureHandle(value: Any?): Long

completedFutureOf

fun <T> completedFutureOf(value: T): WitFuture<T>

completeFuture

fun completeFuture(handle: Long, value: Any?)

fun completeFuture(future: WitFuture<*>, value: Any?)

futureCancelRead

open override fun futureCancelRead(futureHandle: Long): Long

futureCancelWrite

open override fun futureCancelWrite(futureHandle: Long): Long

futureCompleted

fun futureCompleted(handle: Long): Boolean

fun futureCompleted(future: WitFuture<*>): Boolean

futureDropReadable

open override fun futureDropReadable(futureHandle: Long)

futureDropWritable

open override fun futureDropWritable(futureHandle: Long)

futureNew

open override fun futureNew(): Long

futureRead

open override fun futureRead(context: WasiPreview3CanonicalContext, futureHandle: Long, ptr: Int, payloadType: WitPackage.TypeRef): Long

futureValue

fun futureValue(handle: Long): Any?

fun futureValue(future: WitFuture<*>): Any?

futureWrite

open override fun futureWrite(context: WasiPreview3CanonicalContext, futureHandle: Long, ptr: Int, payloadType: WitPackage.TypeRef): Long

handleHttpRequest

fun handleHttpRequest(plugin: WasiComponentInvoker, request: WasiPreview2.HttpRequestSnapshot): WasiPreview2.HttpResponseSnapshot

fun handleHttpRequest(plugin: WasiComponentInvoker, method: String, pathWithQuery: String, scheme: String, authority: String, headers: Map<String, List<ByteArray>>, body: ByteArray): WasiPreview2.HttpResponseSnapshot

httpFields

fun httpFields(headers: Map<String, List<ByteArray>>): WitResource<*>

httpFieldsSnapshot

fun httpFieldsSnapshot(handle: Long): Map<String, List<ByteArray>>

fun httpFieldsSnapshot(fields: WitResource<*>): Map<String, List<ByteArray>>

httpRequestTrailers

fun httpRequestTrailers(handle: Long): WitResult<Map<String, List<ByteArray>>?, Any?>

fun httpRequestTrailers(request: WitResource<*>): WitResult<Map<String, List<ByteArray>>?, Any?>

httpResponseTrailers

fun httpResponseTrailers(handle: Long): WitResult<Map<String, List<ByteArray>>?, Any?>

fun httpResponseTrailers(response: WitResource<*>): WitResult<Map<String, List<ByteArray>>?, Any?>

install

fun <T : WasiHostImportBuilder> install(builder: T): T

pendingFuture

fun <T> pendingFuture(): WitFuture<T>

readByteStreamChunk

suspend fun readByteStreamChunk(handle: Long, maxBytes: Int = DEFAULT_STREAM_BUFFER_CAPACITY): ByteArray?

suspend fun readByteStreamChunk(stream: WitStream<*>, maxBytes: Int = DEFAULT_STREAM_BUFFER_CAPACITY): ByteArray?

streamBytes

fun streamBytes(handle: Long): ByteArray

fun streamBytes(stream: WitStream<*>): ByteArray

streamCancelRead

open override fun streamCancelRead(streamHandle: Long): Long

streamCancelWrite

open override fun streamCancelWrite(streamHandle: Long): Long

streamDirectoryEntries

fun streamDirectoryEntries(handle: Long): List<Map<String, Any?>>

fun streamDirectoryEntries(stream: WitStream<*>): List<Map<String, Any?>>

streamDropReadable

open override fun streamDropReadable(streamHandle: Long)

streamDropWritable

open override fun streamDropWritable(streamHandle: Long)

streamNew

open override fun streamNew(payloadType: WitPackage.TypeRef): Long

streamOf

fun <T> streamOf(values: Iterable<T>): WitStream<T>

streamRead

open override fun streamRead(context: WasiPreview3CanonicalContext, streamHandle: Long, ptr: Int, len: Int, payloadType: WitPackage.TypeRef): Long

streamValues

fun <T> streamValues(handle: Long): List<T>

fun <T> streamValues(stream: WitStream<T>): List<T>

streamWrite

open override fun streamWrite(context: WasiPreview3CanonicalContext, streamHandle: Long, ptr: Int, len: Int, payloadType: WitPackage.TypeRef): Long

tcpLocalAddress

fun tcpLocalAddress(handle: Long): WitResult<Any, Any?>

fun tcpLocalAddress(socket: WitResource<*>): WitResult<Any, Any?>

tcpRemoteAddress

fun tcpRemoteAddress(handle: Long): WitResult<Any, Any?>

fun tcpRemoteAddress(socket: WitResource<*>): WitResult<Any, Any?>

version

fun version(): String