Package: mizu 0.0.1
mizu: Single-Producer Single-Consumer Channels
Provides a single-producer single-consumer channel with bounded capacity, optional timeouts on receives, and sentinel return values for full, timeout, and closed states. The ring buffer is implemented in C: sends and receives are constant-time operations, values are delivered in first-in first-out order, and a closed channel drains its buffered values before reporting the closed state. The transport is in-process: both ends of a channel live in the calling R process, which suits the channel to prototyping producer and consumer designs and to testing channel-based logic.
Authors:
mizu_0.0.1.tar.gz
mizu_0.0.1.zip(r-4.7-x86_64)mizu_0.0.1.zip(r-4.7-arm64)mizu_0.0.1.zip(r-4.6-x86_64)mizu_0.0.1.zip(r-4.6-arm64)
mizu_0.0.1.tar.gz(r-4.7-arm64)mizu_0.0.1.tar.gz(r-4.7-x86_64)mizu_0.0.1.tar.gz(r-4.6-arm64)mizu_0.0.1.tar.gz(r-4.6-x86_64)
mizu_0.0.1.tgz(r-4.6-emscripten)
manual.pdf |manual.html✨
DESCRIPTION |NEWS
card.svg |card.png
mizu/json (API)
| # Install 'mizu' in R: |
| install.packages('mizu', repos = c('https://cran.r-universe.dev', 'https://cloud.r-project.org')) |
Bug tracker:https://github.com/shikokuchuo/mizu-r/issues
Last updated from:0eb3074044. Checks:10 OK. Indexed: yes.
| Target | Result | Time | Files | Syslog |
|---|---|---|---|---|
| linux-devel-arm64 | OK | 94 | ||
| linux-devel-x86_64 | OK | 117 | ||
| source / vignettes | OK | 158 | ||
| linux-release-arm64 | OK | 91 | ||
| linux-release-x86_64 | OK | 109 | ||
| windows-devel-arm64 | OK | 161 | ||
| windows-devel-x86_64 | OK | 103 | ||
| windows-release-arm64 | OK | 191 | ||
| windows-release-x86_64 | OK | 70 | ||
| wasm-release | OK | 96 |
Exports:mizu_inproc_channelmizu_inproc_closemizu_is_sentinelmizu_recvmizu_send
Dependencies:
Readme and manuals
Help Manual
| Help page | Topics |
|---|---|
| Sentinel Values | mizu_closed mizu_full mizu_timeout |
| Create a Channel | mizu_inproc_channel |
| Close a Channel | mizu_inproc_close |
| Test for a mizu Sentinel | mizu_is_sentinel |
| Send and Receive over a Channel | mizu_recv mizu_send |
| Print Methods for mizu Objects | print.mizu_inproc_channel print.mizu_sentinel |