RxPy - 合併事業者が排出をインターリーブするのはなぜですか？

Question

私は2年間RxJavaとRxKotlinをやった後にRxPyを学んでいます。私が気づいていることの1つは、特定の演算子がRxJavaで発生しない狂ったインターリーブを引き起こすことです。

たとえば、flat_map()は、単純なObservableソースの場合、排出物がインターリーブされなくなります。

items = Observable.from_(("Alpha","Beta","Gamma","Delta","Epsilon")) 

items.flat_map(lambda s: Observable.from_(list(s))).subscribe(print) 

OUTPUT：

A 
l 
B 
p 
e 
G 
h 
t 
a 
D 
a 
a 
m 
e 
E 
m 
l 
p 
a 
t 
s 
a 
i 
l 
o 
n 

はしかし、RxJavaまたはRxKotlinで、すべてが、順次、順番にとどまります。

fun main(args: Array<String>) { 
    Observable.just("Alpha","Beta","Gamma","Delta","Epsilon") 
     .flatMap { 
      Observable.from(it.toCharArray().asIterable()) 
     }.subscribe(::println) 
} 

OUTPUT：

A 
l 
p 
h 
a 
B 
e 
t 
a 
G 
a 
m 
m 
a 
D 
e 
l 
t 
a 
E 
p 
s 
i 
l 
o 
n 

私はすべてがMainThread上で実行されていると起こって何の奇妙な非同期スケジューリングが（と思う）がないことを確認しました。

なぜRxPyはこのように動作しますか？私は、複数のソースが一緒にマージされることを扱っているオペレータであれば、これがほとんど起こることに気づきます。デフォルトのスケジューラは何をしていますか？

また、RxPyにはconcat_map()がないのはなぜですか？私はスケジューリングの仕方によっては何とかできないという印象を受けています...

Answer 1

すでに言及したように、flatMapは注文を保証しません。 RxPyは明確なオペレーターとしてconcat_mapを実装していないが、あなたは、 `flatMap`がRxJava順序を尊重するために起こるという事実は、実装の詳細であり、あなたはいけないmapとconcat_allオペレーター

Observable.from_(("Alpha","Beta","Gamma","Delta","Epsilon"))\ 
      .map(lambda s: Observable.from_(list(s)))\ 
      .concat_all()\ 
      .subscribe(print)