2017-01-30 48 views
1

如果我創建了兩個流和連接兩個:斷開歧管流而不關閉其他的流

(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'?

回答

1

是的,有。據stream/connect商務部:

可選需要地圖的參數:

...

  • 下游? - 如果關閉源會關閉水槽。默認爲true。

...

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

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

的感謝!這很好。 – zcaudate