Public Vars
- <! (clj)
- >! (clj)
- Mix (clj)
- Mult (clj)
- Mux (clj)
- Pub (clj)
- admix (clj)
- admix* (clj)
- alt! (clj)
- alts! (clj)
- buffer (clj)
- chan (clj)
- close! (clj)
- do-alt (clj)
- do-alts (clj)
- dropping-buffer (clj)
- filter< (clj)
- filter> (clj)
- go (clj)
- go-loop (clj)
- into (clj)
- ioc-alts! (clj)
- map (clj)
- map< (clj)
- map> (clj)
- mapcat< (clj)
- mapcat> (clj)
- merge (clj)
- mix (clj)
- mult (clj)
- muxch* (clj)
- offer! (clj)
- onto-chan (clj)
- onto-chan! (clj)
- partition (clj)
- partition-by (clj)
- pipe (clj)
- pipeline (clj)
- pipeline-async (clj)
- poll! (clj)
- promise-chan (clj)
- pub (clj)
- put! (clj)
- reduce (clj)
- remove< (clj)
- remove> (clj)
- sliding-buffer (clj)
- solo-mode (clj)
- solo-mode* (clj)
- split (clj)
- sub (clj)
- sub* (clj)
- take (clj)
- take! (clj)
- tap (clj)
- tap* (clj)
- timeout (clj)
- to-chan (clj)
- to-chan! (clj)
- toggle (clj)
- toggle* (clj)
- transduce (clj)
- unblocking-buffer? (clj)
- unique (clj)
- unmix (clj)
- unmix* (clj)
- unmix-all (clj)
- unmix-all* (clj)
- unsub (clj)
- unsub* (clj)
- unsub-all (clj)
- unsub-all* (clj)
- untap (clj)
- untap* (clj)
- untap-all (clj)
- untap-all* (clj)
Back
pipe (clj)
(source)function
(pipe from to)
(pipe from to close?)
Takes elements from the from channel and supplies them to the to
channel. By default, the to channel will be closed when the from
channel closes, but can be determined by the close? parameter. Will
stop consuming the from channel if the to channel closes