RxJava concat 不往下走

2021-08-21 04:13:23 字數 467 閱讀 9563

非常簡單的 concat(組合) 使用測試:

observable.concat(

observable.create(subscriber -> subscriber.onnext("1")),

observable.create(subscriber -> subscriber.onnext("2"))

).subscribe(new action1()

});

然而結果卻只列印了 1 ,沒有列印 2

一分鐘後我突然想起:是不是因為沒有結束事件……

observable.concat(

observable.create(subscriber -> ),

observable.create(subscriber -> )

).subscribe(new action1()

});

測試成功,列印了 1 和 2

「蘋果為什麼不往天上掉?」

天哪!這麼個小不點兒,簡直可以把他塞進杯子裡去!接生婆擺弄著滿身血汙的小生命驚訝地嚷道。這時恰好是1642年聖誕節的清晨,英國東部林肯郡沃爾斯索普村教學的大鐘敲響了,咚!咚!的鐘聲召喚著虔誠的村民去作禮拜。這位早產的男孩隨著教學的鐘聲降臨到人世間,他的哭聲是那麼的微弱,體重也僅及正常嬰兒的一半。尤其...

猴子往下走

問題描述 有一顆二叉樹,最大深度為d,且所有葉子的深度都相同。所有結點從左到右從上到下的編號為1,2,3,2的d次方減1。在結點1處放乙個小猴子,它會往下跑。每個內結點上都有乙個開關,初始全部關閉,當每次有小猴子跑到乙個開關上時,它的狀態都會改變,當到達乙個內結點時,如果開關關閉,小猴子往左走,否則...

猴子往下走

問題描述 有一顆二叉樹,最大深度為d,且所有葉子的深度都相同。所有結點從左到右從上到下的編號為1,2,3,2的d次方減1。在結點1處放乙個小猴子,它會往下跑。每個內結點上都有乙個開關,初始全部關閉,當每次有小猴子跑到乙個開關上時,它的狀態都會改變,當到達乙個內結點時,如果開關關閉,小猴子往左走,否則...