Core channel protocol defining the fundamental operations for all channel implementations in csp-clj.
This protocol abstracts over buffered and unbuffered channels, providing a uniform interface for:
Thread Safety: All methods in this protocol are thread-safe and may be called concurrently from multiple virtual threads.
Core channel protocol defining the fundamental operations for all channel implementations in csp-clj. This protocol abstracts over buffered and unbuffered channels, providing a uniform interface for: - Synchronous/asynchronous value transfer - Channel lifecycle management - Timeout support for blocking operations Thread Safety: All methods in this protocol are thread-safe and may be called concurrently from multiple virtual threads.
Protocol for channel operations.
Implementations of close! must be idempotent — multiple calls should be safe and have no additional effect. This is required because concurrent shutdown paths (e.g., multiplexer dispatch-loop cleanup and tap! undo) may call close! on the same channel from different threads.
Protocol for channel operations. Implementations of close! must be idempotent — multiple calls should be safe and have no additional effect. This is required because concurrent shutdown paths (e.g., multiplexer dispatch-loop cleanup and tap! undo) may call close! on the same channel from different threads.
(close! ch)(closed? ch)(put! ch value)(put! ch value timeout-ms)(take! ch)(take! ch timeout-ms)cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |