mooncakes.io

aqueue
→
cond_var
→
external_loop_integration
→
fs
→
gzip
→
http
→
io
→
js_async
→
os_error
→
pipe
→
process
→
raw_fd
→
semaphore
→
signal
→
socket
→
stdio
→
tls
→
types
→
websocket
→
README
U
CondVar
U
Queue
U
Semaphore
E
BreakFromSpawnLoop
E
TimeoutError
E
TimerCancelled
T
Lazy
- ::LazyLazy::Lazy
- ::waitLazy::wait
T
Mutex
- ::MutexMutex::Mutex
- ::acquireMutex::acquire
- ::releaseMutex::release
- ::try_acquireMutex::try_acquire
T
RetryMethod
T
Task
- ::cancelTask::cancel
- ::try_waitTask::try_wait
- ::waitTask::wait
T
TaskGroup
- ::add_deferTaskGroup::add_defer
- ::return_immediatelyTaskGroup::return_immediately
- ::spawnTaskGroup::spawn
- ::spawn_bgTaskGroup::spawn_bg
- ::spawn_loopTaskGroup::spawn_loop
T
Timer
- ::TimerTimer::Timer
- ::cancelTimer::cancel
- ::refreshTimer::refresh
- ::waitTimer::wait
V
all
V
any
V
is_being_cancelled
V
is_cancellation_error
V
now
V
pause
V
protect_from_cancel
V
retry
V
set_deadlock_handler
V
set_external_event_loop
V
sleep
V
with_task_group
V
with_timeout
V
with_timeout_opt

README

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::fd

source

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

#
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

#
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::fd

#PipeWrite

#PipeWrite::close

#PipeWrite::fd

#pipe

Source Files

#
PipeRead

#
PipeRead::close

#
PipeRead::fd

#
PipeWrite

#
PipeWrite::close

#
PipeWrite::fd

#
pipe