断开歧管流而不关闭其他的流

问题描述:

如果我创建了两个流和连接两个:断开歧管流而不关闭其他的流

(def a (stream/stream)) 
(def b (stream/stream)) 
(stream/connect a b) 

当“a”是封闭的“B”关闭

(stream/closed? b) => false 
(stream/close! a) 
(stream/closed? b) => true 

有没有一种办法从'b'断开'a'而不关闭'b'?

是的,有。据stream/connect商务部:

可选需要地图的参数:

...

  • 下游? - 如果关闭源会关闭水槽。默认为true。

...

所以,你需要连接流如下:

(stream/connect a b {:downstream? false}) 
+0

的感谢!这很好。 – zcaudate