| Use Case | Command | Description |
|---|---|---|
| Create a channel | Concurrent::Channel.new | Creates a new channel |
| Send a value (blocking) | channel.put(value) or channel << value | Sends a value to the channel, blocking if full |
| Receive a value (blocking) | channel.take or channel.receive | Receives a value from the channel, blocking if empty |
| Nonβblocking send | channel.offer(value) | Tries to send, returns immediately |
| Nonβblocking receive | channel.poll | Tries to receive, returns immediately |
| Select from multiple channels | Concurrent::Channel.select | Waits for one of several channels to be ready |
| Channel that fires after a delay | Concurrent::Channel.after(seconds) | Returns a channel that delivers a value once after the delay |
| Periodic ticker channel | Concurrent::Channel.ticker(interval) | Returns a channel that ticks repeatedly at the given interval |
(from /home/chedong/.local/share/rdoc)
π Documentation sourced from {include:file:docs-source/channel.md}
@!macro warn.edge
Error β [not documented]afteraltgogo_loopgo_loop_viago_vianewselectticktickertimer<<eachnextnext?offeroffer!offer?pollpoll!poll?putput!put?receivesendtaketake!take?~Generated by phpman v4.9.26-1-g511901d · Markdown · JSON · MCP Author: Che Dong Under GNU General Public License
2026-07-27 18:53 @216.73.216.199
CrawledBy Mozilla/5.0 AppleWebKit/537.36 (KHTML, like Gecko; compatible; ClaudeBot/1.0; +claudebot@anthropic.com)
Enhanced by LLM: deepseek-v4-flash / taotoken.net / www.chedong.com - original format