moonbitlang/async/pipe - mooncakes.io

README
U
CondVar
U
Queue
U
Semaphore
E
BreakFromSpawnLoop
E
TimeoutError
E
TimerCancelled
E
WaitedTaskAlreadyCancelled
- ::LazyLazy::Lazy
- ::waitLazy::wait
- ::MutexMutex::Mutex
- ::acquireMutex::acquire
- ::releaseMutex::release
- ::try_acquireMutex::try_acquire
T
RetryMethod
- ::cancelTask::cancel
- ::try_waitTask::try_wait
- ::waitTask::wait
- ::add_deferTaskGroup::add_defer
- ::return_immediatelyTaskGroup::return_immediately
- ::spawnTaskGroup::spawn
- ::spawn_bgTaskGroup::spawn_bg
- ::spawn_loopTaskGroup::spawn_loop
- ::TimerTimer::Timer
- ::cancelTimer::cancel
- ::refreshTimer::refresh
- ::waitTimer::wait
V
all
V
any
V
handle_cancellation
V
is_being_cancelled
V
is_cancellation_error
V
now
V
pause
V
platform
V
protect_from_cancel
V
retry
V
set_deadlock_handler
V
set_external_event_loop
V
sleep
V
with_cancellation_handler
V
with_task_group
V
with_timeout
V
with_timeout_opt

moonbitlang/async/pipe does not have a README file

PipeRead

type PipeRead

The read end of a pipe

impl Reader for PipeRead

async fn _direct_read(self : PipeRead, buf : FixedArray[Byte], offset~ : Int, max_len~ : Int) -> Int

source

Read data from the read end of a pipe using read(2) system call. For pipe.read(buf, offset~, max_len~), at most max_len bytes of data will be written to buf, starting from offset. The number of read bytes will be returned.

At most one task can read from a pipe at any time. To allow multiple reader, use a worker task for reading and use @async.Queue to distribute the data.

fn _get_internal_buffer(self : PipeRead) -> @moonbitlang/async/io.ReaderBuffer
ReaderBuffer

source

PipeRead::close

source

fn PipeRead::close(self : PipeRead) -> Unit

PipeRead::drop

source

async fn PipeRead::drop(self : PipeRead, len : Int) -> Int

PipeRead::fd

source

fn PipeRead::fd(self : PipeRead) -> Int

PipeRead::read

source

async fn PipeRead::read(self : PipeRead, dst : FixedArray[Byte], offset? : Int, max_len? : Int) -> Int

PipeRead::read_all

source

async fn PipeRead::read_all(self : PipeRead) -> &@moonbitlang/async/io.Data
Data

PipeRead::read_exactly

source

async fn PipeRead::read_exactly(self : PipeRead, len : Int) -> Bytes

PipeRead::read_some

source

async fn PipeRead::read_some(self : PipeRead, max_len? : Int) -> Bytes?

PipeRead::read_until

source

async fn PipeRead::read_until(self : PipeRead, sep : StringView) -> String?

PipeWrite

source

type PipeWrite

The write end of a pipe

impl Writer for PipeWrite

PipeWrite::close

source

fn PipeWrite::close(self : PipeWrite) -> Unit

PipeWrite::fd

source

fn PipeWrite::fd(self : PipeWrite) -> Int

PipeWrite::write

source

async fn PipeWrite::write(self : PipeWrite, data : &@moonbitlang/async/io.Data
Data) -> Unit

PipeWrite::write_once

source

async fn PipeWrite::write_once(self : PipeWrite, buf : Bytes, offset~ : Int, len~ : Int) -> Int

PipeWrite::write_reader

source

async fn PipeWrite::write_reader(self : PipeWrite, reader : &@moonbitlang/async/io.Reader
Reader) -> Unit

pipe

source

fn pipe() -> (PipeRead, PipeWrite) raise

Create a pipe using pipe(2) system call. Return the read end and write end of the pipe.

Source Files

Site source Report issue Packages Build queue Skills Statistics

#PipeRead

#PipeRead::close

#PipeRead::drop

#PipeRead::fd

#PipeRead::read

#PipeRead::read_all

#PipeRead::read_exactly

#PipeRead::read_some

#PipeRead::read_until

#PipeWrite

#PipeWrite::close

#PipeWrite::fd

#PipeWrite::write

#PipeWrite::write_once

#PipeWrite::write_reader

#pipe

Source Files

PipeRead

PipeRead::close

PipeRead::drop

PipeRead::fd

PipeRead::read

PipeRead::read_all

PipeRead::read_exactly

PipeRead::read_some

PipeRead::read_until

PipeWrite

PipeWrite::close

PipeWrite::fd

PipeWrite::write

PipeWrite::write_once

PipeWrite::write_reader

pipe