Ecosyste.ms: Packages

An open API service providing package, version and dependency metadata of many open source software ecosystems and registries.

crates.io "channel" keyword

Top 0.6% on crates.io
crossbeam-channel 0.5.12
Multi-producer multi-consumer channels for message passing
40 versions - Latest release: 3 months ago - 1,372 dependent packages - 36,222 dependent repositories - 145 million downloads total - 6,543 stars on GitHub - 3 maintainers
Top 7.7% on crates.io
want 0.3.1 💰
Detect when another Future wants a result.
11 versions - Latest release: 12 months ago - 5 dependent packages - 32,878 dependent repositories - 125 million downloads total - 36 stars on GitHub - 1 maintainer
Top 4.1% on crates.io
concurrent-queue 2.5.0
Concurrent multi-producer multi-consumer queue
16 versions - Latest release: about 1 month ago - 56 dependent packages - 12,062 dependent repositories - 48.9 million downloads total - 233 stars on GitHub - 1 maintainer
Top 2.2% on crates.io
flume 0.11.0 💰
A blazingly fast multi-producer channel
37 versions - Latest release: 10 months ago - 460 dependent packages - 4,451 dependent repositories - 24.6 million downloads total - 2,036 stars on GitHub - 1 maintainer
Top 3.2% on crates.io
local-channel 0.1.5
A non-threadsafe multi-producer, single-consumer, futures-aware, FIFO queue
7 versions - Latest release: 7 months ago - 4 dependent packages - 3,077 dependent repositories - 13.8 million downloads total - 653 stars on GitHub - 1 maintainer
Top 6.3% on crates.io
sluice 0.5.5 💰
Efficient ring buffer for byte buffers, FIFO queues, and SPSC channels
11 versions - Latest release: almost 3 years ago - 17 dependent packages - 1,304 dependent repositories - 5.11 million downloads total - 97 stars on GitHub - 1 maintainer
Top 7.0% on crates.io
oneshot 0.1.6
Oneshot spsc channel with (potentially) lock-free non-blocking send, and a receiver supporting bo...
8 versions - Latest release: 9 months ago - 45 dependent packages - 426 dependent repositories - 3.66 million downloads total - 66 stars on GitHub - 1 maintainer
ginepro 0.7.2
A client-side gRPC channel implementation for tonic
16 versions - Latest release: about 1 month ago - 1 dependent package - 1 dependent repositories - 1.87 million downloads total - 118 stars on GitHub - 2 maintainers
relay 0.1.1 💰
A lightweight oneshot Future channel.
3 versions - Latest release: over 6 years ago - 2 dependent packages - 425 dependent repositories - 1.42 million downloads total - 2 stars on GitHub - 1 maintainer
Top 4.2% on crates.io
dasp_frame 0.11.0
An abstraction for audio PCM DSP frames, along with useful conversions and operations.
1 version - Latest release: about 4 years ago - 11 dependent packages - 585 dependent repositories - 1.41 million downloads total - 817 stars on GitHub - 1 maintainer
Top 6.9% on crates.io
spmc 0.3.0 💰
Simple SPMC channel
6 versions - Latest release: almost 5 years ago - 29 dependent packages - 383 dependent repositories - 1.01 million downloads total - 56 stars on GitHub - 1 maintainer
Top 6.4% on crates.io
kanal 0.1.0-pre8
The fast sync and async channel that Rust deserves
10 versions - Latest release: over 1 year ago - 22 dependent packages - 4 dependent repositories - 588 thousand downloads total - 1,237 stars on GitHub - 1 maintainer
Top 8.9% on crates.io
thingbuf 0.1.6 💰
I'm at the buffer pool. I'm at the MPSC channel. I'm at the combination MPSC channel and buffer p...
7 versions - Latest release: about 1 month ago - 3 dependent packages - 15 dependent repositories - 442 thousand downloads total - 248 stars on GitHub - 1 maintainer
broadcaster 1.0.0
Broadcasting futures mpmc channel
10 versions - Latest release: over 4 years ago - 8 dependent packages - 124 dependent repositories - 427 thousand downloads total - 24 stars on GitHub - 1 maintainer
Top 5.1% on crates.io
bus 2.4.1
A lock-free, bounded, single-producer, multi-consumer, broadcast channel.
25 versions - Latest release: 9 months ago - 31 dependent packages - 174 dependent repositories - 419 thousand downloads total - 750 stars on GitHub - 1 maintainer
Top 5.6% on crates.io
chan 0.1.23
DEPRECATED. Use crossbeam-channel instead.
21 versions - Latest release: almost 6 years ago - 52 dependent packages - 69 dependent repositories - 416 thousand downloads total - 391 stars on GitHub - 1 maintainer
Top 7.8% on crates.io
async-oneshot 0.5.9
A fast, small, full-featured, async-aware oneshot channel.
11 versions - Latest release: about 3 years ago - 28 dependent packages - 288 dependent repositories - 368 thousand downloads total - 60 stars on GitHub - 3 maintainers
crossfire 1.0.1
channels for async and threads
10 versions - Latest release: 9 months ago - 2 dependent packages - 12 dependent repositories - 208 thousand downloads total - 46 stars on GitHub - 1 maintainer
ring-channel 0.12.0
Bounded MPMC channel abstraction on top of a ring buffer
19 versions - Latest release: 8 months ago - 3 dependent packages - 5 dependent repositories - 168 thousand downloads total - 36 stars on GitHub - 1 maintainer
conqueue 0.4.0
Yet another multi-producer, single-consumer queue (MPSC)
6 versions - Latest release: over 3 years ago - 1 dependent package - 22 dependent repositories - 156 thousand downloads total - 9 stars on GitHub - 2 maintainers
oneshot-uniffi 0.1.6
Patched version of oneshot specifically for the UniFFI project. This removes the `loom` target a...
2 versions - Latest release: 5 months ago - 1 dependent package - 156 thousand downloads total - 66 stars on GitHub - 1 maintainer
Top 6.8% on crates.io
chan-signal 0.3.3
DEPRECATED. Use crossbeam-channel and signal-hook instead.
12 versions - Latest release: almost 5 years ago - 32 dependent packages - 38 dependent repositories - 137 thousand downloads total - 126 stars on GitHub - 1 maintainer
tachyonix 0.3.0
A very fast asynchronous, multi-producer, single-consumer bounded channel.
5 versions - Latest release: 15 days ago - 5 dependent packages - 1 dependent repositories - 76.8 thousand downloads total - 98 stars on GitHub - 1 maintainer
ibc-core-channel-types 0.52.0
Maintained by `ibc-rs`, encapsulates essential ICS-4 Channel Semantics data structures and do...
9 versions - Latest release: about 1 month ago - 5 dependent packages - 53.7 thousand downloads total - 112 stars on GitHub - 2 maintainers
ibc-core-channel 0.52.0
Maintained by `ibc-rs`, contains the implementation of the ICS-04 Channel & Packet Semantics ...
9 versions - Latest release: about 1 month ago - 2 dependent packages - 52.4 thousand downloads total - 154 stars on GitHub - 4 maintainers
signal-notify 0.1.3
Catch OS signals with standard mpsc channel
4 versions - Latest release: over 6 years ago - 2 dependent packages - 6 dependent repositories - 48.8 thousand downloads total - 3 stars on GitHub - 1 maintainer
catty 0.1.5
Send and await a value asynchronously
6 versions - Latest release: almost 2 years ago - 2 dependent packages - 19 dependent repositories - 44.6 thousand downloads total - 7 stars on GitHub - 1 maintainer
watch 0.2.3
A synchronous message passing channel that only retains the most recent value.
5 versions - Latest release: about 1 year ago - 3 dependent packages - 3 dependent repositories - 34.2 thousand downloads total - 13 stars on GitHub - 1 maintainer
tsyncp 0.3.0
Async channel APIs (mpsc, broadcast, barrier, etc) over TCP for message-passing.
13 versions - Latest release: about 2 years ago - 34.2 thousand downloads total - 32 stars on GitHub - 1 maintainer
barrage 0.2.3
An async broadcast channel
5 versions - Latest release: almost 2 years ago - 1 dependent package - 16 dependent repositories - 31.7 thousand downloads total - 6 stars on GitHub - 1 maintainer
workflow-core 0.12.1
Utilities and curated re-exports for async rust native and browser development
27 versions - Latest release: about 1 month ago - 28 dependent packages - 1 dependent repositories - 31 thousand downloads total - 32 stars on GitHub - 2 maintainers
rust-latest 1.4.1
A CLI tool to determine the latest version of the Rust toolchain.
5 versions - Latest release: about 2 years ago - 30.8 thousand downloads total - 7 stars on GitHub - 1 maintainer
remoc 0.13.0
🦑 Remote multiplexed objects, channels, observable collections and RPC making remote interactions...
45 versions - Latest release: about 2 months ago - 1 dependent package - 3 dependent repositories - 30.7 thousand downloads total - 147 stars on GitHub - 1 maintainer
Top 9.0% on crates.io
local-sync 0.1.1
Non-threadsafe data structure for async usage
7 versions - Latest release: 10 months ago - 11 dependent packages - 6 dependent repositories - 26.6 thousand downloads total - 1 maintainer
generic-channel 0.2.0
Generic `Sender` and `Receiver` abstract between several channel implementations: std, crossbeam-...
3 versions - Latest release: over 5 years ago - 2 dependent packages - 2 dependent repositories - 24.6 thousand downloads total - 2 stars on GitHub - 1 maintainer
two-lock-queue 0.1.1
A MPMC channel based on the michael-scott two lock queue algorithm.
2 versions - Latest release: over 6 years ago - 4 dependent packages - 11 dependent repositories - 22.8 thousand downloads total - 16 stars on GitHub - 1 maintainer
workflow-task 0.12.1
Rust application development framework for native and web applications
25 versions - Latest release: about 1 month ago - 3 dependent packages - 1 dependent repositories - 22.5 thousand downloads total - 32 stars on GitHub - 2 maintainers
wasm-rs-shared-channel 0.1.0
Shared channel for WebAssembly
1 version - Latest release: over 3 years ago - 2 dependent packages - 1 dependent repositories - 22 thousand downloads total - 37 stars on GitHub - 1 maintainer
mpsc 0.2.3
mpsc channel
5 versions - Latest release: 8 months ago - 6 dependent packages - 3 dependent repositories - 19.3 thousand downloads total - 9 stars on GitHub - 1 maintainer
async-thread 0.1.2
Futures version of std::thread
3 versions - Latest release: over 4 years ago - 2 dependent packages - 3 dependent repositories - 18.3 thousand downloads total - 3 stars on GitHub - 1 maintainer
single_value_channel 1.2.2
Concurrent single-value update and receive channel
5 versions - Latest release: over 3 years ago - 4 dependent packages - 11 dependent repositories - 17.9 thousand downloads total - 21 stars on GitHub - 1 maintainer
whisk 0.12.0
Simple and fast lockless async channels
16 versions - Latest release: 12 months ago - 5 dependent packages - 3 dependent repositories - 15.6 thousand downloads total - 13 stars on GitHub - 1 maintainer
ach-util 0.1.16
Atomic Channel
16 versions - Latest release: almost 2 years ago - 15 dependent packages - 1 dependent repositories - 15.3 thousand downloads total - 4 stars on GitHub - 1 maintainer
ex-futures 0.4.9
An extension of `futures`
19 versions - Latest release: over 6 years ago - 1 dependent package - 1 dependent repositories - 12.8 thousand downloads total - 1 stars on GitHub - 1 maintainer
clocked-dispatch 4.0.2
Provides a clocked message dispatch service
18 versions - Latest release: over 5 years ago - 12.5 thousand downloads total - 2 stars on GitHub - 1 maintainer
hopper 0.4.2
an unbounded mpsc with bounded memory
14 versions - Latest release: over 6 years ago - 1 dependent package - 2 dependent repositories - 12 thousand downloads total - 49 stars on GitHub - 2 maintainers
ach-cell 0.1.17
Atomic Channel
17 versions - Latest release: almost 2 years ago - 5 dependent packages - 1 dependent repositories - 11.8 thousand downloads total - 4 stars on GitHub - 1 maintainer
async-watch 0.3.1
Async watch channel
4 versions - Latest release: over 3 years ago - 11.7 thousand downloads total - 6 stars on GitHub - 1 maintainer
bchannel 0.0.10
A better channel API
10 versions - Latest release: about 8 years ago - 1 dependent package - 10.8 thousand downloads total - 3 stars on GitHub - 1 maintainer
pipe-channel 1.3.0
Channel implementation based on pipes
9 versions - Latest release: over 4 years ago - 1 dependent package - 3 dependent repositories - 10.7 thousand downloads total - 2 stars on GitHub - 2 maintainers
atticus 0.3.0
A mimimal API to create asynchronous actors
6 versions - Latest release: about 1 month ago - 2 dependent repositories - 10.1 thousand downloads total - 1 stars on GitHub - 1 maintainer
ach-ring 0.1.9
Atomic Channel
10 versions - Latest release: about 2 years ago - 5 dependent packages - 1 dependent repositories - 10.1 thousand downloads total - 4 stars on GitHub - 1 maintainer
loole 0.3.0
A safe async/sync multi-producer, multi-consumer channel
21 versions - Latest release: 5 months ago - 8.81 thousand downloads total - 148 stars on GitHub - 1 maintainer
ach-array 0.1.8
Atomic Channel
9 versions - Latest release: about 2 years ago - 3 dependent packages - 8.48 thousand downloads total - 4 stars on GitHub - 1 maintainer
channels 0.11.2
Bidirectional channel-like communication over generic Read/Write streams
25 versions - Latest release: 3 months ago - 7.66 thousand downloads total - 7 stars on GitHub - 1 maintainer
ipc-rpc 1.2.6
A wrapper over servo/ipc-channel which provides many high level features
10 versions - Latest release: over 1 year ago - 1 dependent package - 1 dependent repositories - 7.1 thousand downloads total - 7 stars on GitHub - 1 maintainer
superchan 0.0.7
Communicate over a network using a channel-like API.
7 versions - Latest release: over 9 years ago - 6.41 thousand downloads total - 11 stars on GitHub - 1 maintainer
ach-mpmc 0.2.0
Atomic Channel
6 versions - Latest release: almost 2 years ago - 2 dependent packages - 1 dependent repositories - 6.36 thousand downloads total - 4 stars on GitHub - 1 maintainer
async_ach-waker 0.2.1
Async Atomic Channel
5 versions - Latest release: over 1 year ago - 3 dependent packages - 2 dependent repositories - 6.2 thousand downloads total - 0 stars on GitHub - 1 maintainer
async-transmit 0.3.4 💰
Trait for transmitting data to peers asynchronously.
9 versions - Latest release: 6 months ago - 5.83 thousand downloads total - 1 stars on GitHub - 1 maintainer
heph-inbox 0.2.3
Bounded capacity channel designed to be used as inbox for actors. Also supports one shot channels.
8 versions - Latest release: almost 2 years ago - 2 dependent packages - 1 dependent repositories - 5.81 thousand downloads total - 2 stars on GitHub - 1 maintainer
ach-pubsub 0.2.0
Atomic Channel
11 versions - Latest release: almost 2 years ago - 2 dependent packages - 1 dependent repositories - 5.68 thousand downloads total - 4 stars on GitHub - 1 maintainer
ach-linked 0.2.2
Atomic Channel
7 versions - Latest release: over 1 year ago - 1 dependent package - 5.55 thousand downloads total - 4 stars on GitHub - 1 maintainer
secc 0.0.10
Implements a Skip-Enabled Concurrent Channel (SECC) for Rust
6 versions - Latest release: over 4 years ago - 2 dependent packages - 3 dependent repositories - 5.42 thousand downloads total - 5 stars on GitHub - 1 maintainer
async_ach-notify 0.1.6
Async Atomic Channel
7 versions - Latest release: over 1 year ago - 6 dependent packages - 1 dependent repositories - 5.41 thousand downloads total - 0 stars on GitHub - 1 maintainer
latest 0.1.1
A channel-esque type that only stores the last value that was sent.
4 versions - Latest release: over 8 years ago - 5.37 thousand downloads total - 0 stars on GitHub - 1 maintainer
ach-once 0.1.5
Atomic Channel
6 versions - Latest release: over 2 years ago - 2 dependent packages - 4.83 thousand downloads total - 4 stars on GitHub - 1 maintainer
hyperbridge 0.2.5
Fast multi-producer multi-consumer channel with async support
15 versions - Latest release: over 1 year ago - 4.74 thousand downloads total - 100 stars on GitHub - 1 maintainer
dialectic 0.4.1
Transport-polymorphic, asynchronous session types for Rust
6 versions - Latest release: about 3 years ago - 6 dependent packages - 2 dependent repositories - 4.72 thousand downloads total - 60 stars on GitHub - 2 maintainers
ump 0.12.1
Micro message passing library for threads/tasks communication.
14 versions - Latest release: 8 months ago - 1 dependent package - 4.61 thousand downloads total - 1 maintainer
multishot 0.3.2
An async, lock-free, reusable channel for sending single values to asynchronous tasks.
5 versions - Latest release: 2 months ago - 1 dependent package - 1 dependent repositories - 4.51 thousand downloads total - 2 stars on GitHub - 1 maintainer
ach-option 0.1.0
Atomic Channel
1 version - Latest release: about 2 years ago - 3 dependent packages - 4.47 thousand downloads total - 4 stars on GitHub - 1 maintainer
ruspiro-channel 0.1.1
Bare Metal Channel implementations for `no-std` environments, only requiring an allocator to be ...
2 versions - Latest release: about 3 years ago - 1 dependent package - 2 dependent repositories - 4.46 thousand downloads total - 3 stars on GitHub - 1 maintainer
tcp-channel 0.3.2
SPSC channels, working on everything that implements Read and Write
6 versions - Latest release: about 5 years ago - 4.41 thousand downloads total - 5 stars on GitHub - 1 maintainer
mpmcpq 0.9.3
Multi-producer multi-consumer Priority Queue
12 versions - Latest release: over 1 year ago - 1 dependent package - 1 dependent repositories - 4.32 thousand downloads total - 1 stars on GitHub - 1 maintainer
ductile 0.3.0
A channel implementation that allows both local in-memory channels and remote TCP-based channels ...
4 versions - Latest release: over 1 year ago - 2 dependent repositories - 4.31 thousand downloads total - 6 stars on GitHub - 1 maintainer
reqchan 0.5.8
This is a channel for requesting and receiving data. Each channel has only one requesting end, bu...
7 versions - Latest release: over 6 years ago - 4.18 thousand downloads total - 2 stars on GitHub - 1 maintainer
burst-pool 0.5.1
A SPMC channel optimised for bursts of activity
6 versions - Latest release: over 6 years ago - 3.96 thousand downloads total - 3 stars on GitHub - 1 maintainer
crosstalk 0.2.6
An extremely lightweight, topic-based, cross-thread, in-memory communication library
12 versions - Latest release: 2 months ago - 3.87 thousand downloads total - 2 stars on GitHub - 1 maintainer
diath 0.5.1
diath is a light-weight library for communication between tokio async tasks
11 versions - Latest release: about 2 years ago - 3.83 thousand downloads total - 0 stars on GitHub - 1 maintainer
ach-lazy 0.1.2
Atomic Channel
3 versions - Latest release: over 2 years ago - 2 dependent packages - 1 dependent repositories - 3.48 thousand downloads total - 4 stars on GitHub - 1 maintainer
bidirectional-channel 0.3.1
A channel where receivers can respond to a message, and senders can wait for a response.
7 versions - Latest release: almost 3 years ago - 3.39 thousand downloads total - 1 stars on GitHub - 1 maintainer
taskpipe 0.1.2
A simple, multithreaded pipeline library
3 versions - Latest release: over 9 years ago - 3.37 thousand downloads total - 0 stars on GitHub - 1 maintainer
ach 0.2.1
Atomic Channel
8 versions - Latest release: almost 2 years ago - 1 dependent package - 3.34 thousand downloads total - 4 stars on GitHub - 1 maintainer
future_pubsub 0.1.3
A tokio based publish-subscibe channel
4 versions - Latest release: over 6 years ago - 3.32 thousand downloads total - 1 maintainer
future-bus 0.2.1
Futures based SPMC channel (bus)
3 versions - Latest release: over 4 years ago - 1 dependent repositories - 3.29 thousand downloads total - 2 stars on GitHub - 1 maintainer
crosstalk-macros 0.2.6
Procedural macros for crosstalk — An extremely lightweight, topic-based, cross-thread, in-memory ...
9 versions - Latest release: 2 months ago - 1 dependent package - 3.14 thousand downloads total - 2 stars on GitHub - 1 maintainer
batch-channel 0.3.7
async channel that reduces overhead by reading and writing many values at once
12 versions - Latest release: 8 months ago - 3.13 thousand downloads total - 0 stars on GitHub - 1 maintainer
ach-spsc 0.2.0
Atomic Channel
4 versions - Latest release: almost 2 years ago - 2 dependent packages - 1 dependent repositories - 3.11 thousand downloads total - 4 stars on GitHub - 1 maintainer
funnel 1.1.0
A simple data structure that makes it easy to read from multiple channels from a single source
3 versions - Latest release: almost 8 years ago - 2.93 thousand downloads total - 1 maintainer
ergo_sync 0.1.0
Methods and types for making working with the filesystem ergonomic, therefore fun.
1 version - Latest release: over 6 years ago - 1 dependent package - 1 dependent repositories - 2.84 thousand downloads total - 5 stars on GitHub - 1 maintainer
upc 0.5.0
USB packet channel (UPC): provides a reliable, packet-based transport over USB.
11 versions - Latest release: about 1 month ago - 1 dependent package - 2.81 thousand downloads total - 2 stars on GitHub - 1 maintainer
dialectic-compiler 0.1.0
Session type macro compiler for the Dialectic crate
1 version - Latest release: about 3 years ago - 1 dependent package - 2 dependent repositories - 2.78 thousand downloads total - 60 stars on GitHub - 2 maintainers
dialectic-macro 0.1.0
Procedural macros used by and exported from the Dialectic crate
1 version - Latest release: about 3 years ago - 1 dependent package - 2 dependent repositories - 2.76 thousand downloads total - 60 stars on GitHub - 2 maintainers
async_ach-spsc 0.2.0
Async Atomic Channel
6 versions - Latest release: almost 2 years ago - 1 dependent package - 2.51 thousand downloads total - 0 stars on GitHub - 1 maintainer
async_ach-watch 0.1.4
Async Atomic Channel
5 versions - Latest release: about 2 years ago - 1 dependent package - 2.5 thousand downloads total - 0 stars on GitHub - 1 maintainer
skipchannel 2.0.1
skipchannels allow to communicate between threads, but always skip to the last sent value
3 versions - Latest release: almost 4 years ago - 2 dependent repositories - 2.42 thousand downloads total - 1 stars on GitHub - 1 maintainer
async_ach-ring 0.1.3
Async Atomic Channel
4 versions - Latest release: about 2 years ago - 2 dependent packages - 1 dependent repositories - 2.38 thousand downloads total - 0 stars on GitHub - 1 maintainer
rust_release_artefact 0.1.3
Safely extract installable files from Rust release artefacts.
4 versions - Latest release: about 6 years ago - 1 dependent repositories - 2.37 thousand downloads total - 0 stars on GitLab.com - 1 maintainer
async_ach-cell 0.1.2
Async Atomic Channel
3 versions - Latest release: about 2 years ago - 2 dependent packages - 1 dependent repositories - 2.18 thousand downloads total - 0 stars on GitHub - 1 maintainer
Related Keywords
async 51 rust 42 mpmc 25 atomic 25 no-heap 22 mpsc 18 sync 16 futures 16 thread 15 concurrency 14 asynchronous 14 synchronization 10 once 9 message 9 broadcast 9 oneshot 9 threads 8 lock-free 8 types 8 channels 7 rpc 7 message-passing 7 spmc 7 session 7 protocols 7 actor 6 spsc 6 protocol 6 concurrent 5 queue 5 fifo 5 tcp 4 signal 4 stream 4 ring-buffer 4 crossbeam 4 bus 4 select 4 wasm 3 network 3 tokio 3 non-blocking 3 networking 3 sender 3 messaging 3 io 3 release 3 parallelism 3 pipe 3 turn 2 multiplexer 2 remote 2 response 2 websocket-server 2 websocket-client 2 websocket 2 webassembly 2 terminal 2 rfc8016 2 receiver 2 mobility 2 ring 2 distributed 2 threadpool 2 no_std 2 lockfree 2 multithreading 2 pubsub 2 golang 2 local 2 macro 2 worker 2 async-await 2 web 2 javascript 2 os 2 merfolk 2 ibc 2 cosmos 2 blockchain 2 tendermint 2 state 2 request 2 rpc-server 2 rpc-library 2 rpc-framework 2 rpc-client 2 nwjs 2 nodewebkit 2 logging 2 html 2 dom-manipulation 2 dom 2 asynchronous-programming 2 browser 2 data 1 write 1 workflow 1 multi-consumer 1 clone 1