🥮 mooncakes.io
    Sign in

    #Stream

    This package provides abstraction for Streams, including readable streams and writable streams.

    The goal is to provide an abstraction for stream in Node.js, stream in wasi-io, and other IO-related library, such as libuv.

    With the foundation, there will be higher level operations, such as buffered streams, text streams, etc.

    Closable

    source
    pub(open) trait Closable {
      close(Self) -> Unit
    }

    Flushable

    source
    pub(open) trait Flushable {
      flush(Self) -> 
    T    [Unit]
    }

    InputStream

    source
    pub(open) trait InputStream : Closable {
      read(Self, FixedArray[Byte], offset? : Int, max_len? : Int) -> 
    T    [Int?]
    }

    This trait represents an interface that provides the ability for low level async read operations.

    The Self here may represent a stream / file descriptor, or a stream / file descriptor + event loop.

    OutputStream

    source
    pub(open) trait OutputStream : Closable + Flushable {
      write(Self, BytesView) -> 
    T    [Unit]
    }

    This trait represents an interface that provides the ability for low level async write operations.

    The Self here may represent a stream / file descriptor, or a stream / file descriptor + event loop.

    Reader

    source
    pub(open) trait Reader : Closable {
      read(Self, StringBuilder, max_len? : Int) -> 
    T    [Unit?]
    }

    This trait represents an interface that provides the ability for async read operations based on Chars.

    The Self here may represent a stream / file descriptor, or a stream / file descriptor + event loop.

    Writer

    source
    pub(open) trait Writer : Closable + Flushable {
      write(Self, StringView) -> 
    T    [Unit]
    }

    This trait represents an interface that provides the ability for async write operations based on Chars.

    The Self here may represent a stream / file descriptor, or a stream / file descriptor + event loop.

    AsyncIterable

    source
    pub(all) type AsyncIterable[T] async () -> T

    AsyncIterable::inner

    source
    #deprecated("Use `struct T(A)` to declare a newtype and use `.0` access the underlying type instead.")
    fn[T] AsyncIterable::inner(self : AsyncIterable[T]) -> (async () -> T)
    Convert newtype to its underlying type, automatically derived.

    BufferedReader

    source
    type BufferedReader

    A reader that buffers the input stream and provides line reading capabilities.

    BufferedReader::next_line

    source

    BufferedReader::read_line

    source

    StringReader

    source
    type StringReader

    A reader based on a string

    buffered_reader

    source
    fn buffered_reader(stream : &Reader) -> BufferedReader

    Create a buffered reader from a reader

    input_stream_reader

    source
    fn[T : InputStream + Closable] input_stream_reader(stream : T, encoding? : 
    Encoding    , buffer_size? : Int) -> &Reader

    Create a reader from an input stream through the given encoding.

    output_stream_writer

    source
    fn[T : OutputStream + Closable + Flushable] output_stream_writer(stream : T, encoding? : 
    Encoding    ) -> &Writer

    Create a writer from an output stream through the given encoding.

    string_reader

    source
    fn string_reader(string : String) -> StringReader

    Creates a new StringReader based on a string

    Source Files

    Powered by MoonBit

    Site sourceReport issuePackagesBuild queueSkillsStatistics

    © 2026 mooncakes.io