RXJS如何将Observable <T []>转换为Observable <T>

iam1me

我想获取一个Observable <T []>并将其转换为Observable <T>,以便将来自Observable <T []>的每个数组分解,然后分别通过发出该数组的各个元素Observable <T>。

是否有执行此操作的标准操作员?我已经搜索了,但是什么也没找到。谢谢。


指向concatMap / flatMap的方向后,我提出了以下一般解决方案:

var source: Observable<T[]>;
...
var splitSource = source.flatMap<T>((x:T[]) => { return Rx.Observable.fromArray(x); });
用户名

您可以这样使用concatMap

function identity (x) {return x}

var obs_of_array$ = Rx.Observable.return(['1','2','you got it'])
    .concatMap(identity)

之所以concatMap可行,是因为它还接受数组(以及可观察和承诺)作为您作为参数传递的函数选择器的返回值。Jsbin这里,文件在这里

因此,作为参数传递的数组将成为选择器函数的返回值,然后在遵守concatMap数组顺序的情况下运算符进行展

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

如何将linq查询的结果转换为List(Of T)

来自分类Dev

如何将void *转换为size_t?

来自分类Dev

如何将IEnumerable(无类型)转换为IQueryable <T>?

来自分类Dev

如何将int转换为int8_t?

来自分类Dev

如何将List <T>转换为对象

来自分类Dev

如何将timestamp_t转换为实时?

来自分类Dev

如何将类型A <T>的通用对象转换为A <T'>?

来自分类Dev

如何将通用T转换为TObject?

来自分类Dev

如何将TObject强制转换为TObjectList <T>?

来自分类Dev

如何将ICollection <T>转换为IReadOnlyCollection <T>?

来自分类Dev

如何将List <T>转换为List <dynamic> WPF

来自分类Dev

如何将List << MyClass>强制转换为List <T>?

来自分类Dev

RxJava引入了Single <T>。如何将Observable <T>转换为Single <T>?

来自分类Dev

如何将Stream <T?>转换为Stream <T>

来自分类Dev

如何将char转换为wchar_t *?

来自分类Dev

如何将std :: string转换为wchar_t *

来自分类Dev

如何将std :: string转换为wchar_t *

来自分类Dev

如何将抽象类转换为T类型?

来自分类Dev

Crystal如何将Array(T)转换为Array(T?)

来自分类Dev

如何将void *转换为size_t?

来自分类Dev

如何将IEnumerable(无类型)转换为IQueryable <T>?

来自分类Dev

如何将timestamp_t转换为实时?

来自分类Dev

如何将DStream [List [T]]转换为DStream [T]

来自分类Dev

如何将List << MyClass>强制转换为List <T>?

来自分类Dev

如何将IEnumerable <AnonymousType>转换为List <T>?

来自分类Dev

Rx将Observable <List <T >>转换为Observable <T>

来自分类Dev

如何将Observable转换为FirebaseObjectObservable

来自分类Dev

如何将 BinaryExpression 转换为 Expression<Func<T, bool>>?

来自分类Dev

如何将 RealmList<T> 转换为 RealmResults<T>

Related 相关文章

热门标签

归档