- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我们如何转换:
Rx.Observable.timer(3000).mapTo({ id: 1 })
到 RxJS 6?
例如,如果我们:
import { Observable, timer } from 'rxjs';
我们仍然得到:
[ts] Property 'timer' does not exist on type 'typeof Observable'.
总而言之,我正在尝试获取这个示例 (From this tutorial)上类:
// Simulate HTTP requests
const getPostOne$ = Rx.Observable.timer(3000).mapTo({id: 1});
const getPostTwo$ = Rx.Observable.timer(1000).mapTo({id: 2});
Rx.Observable.concat(getPostOne$, getPostTwo$).subscribe(res => console.log(res));
最佳答案
使用新方法来执行可管道运算符,我们不再使用 .
来链接可观察量,而是使用管道并传入以逗号分隔的运算符。在您的场景中我们会做的示例
import { timer, concat } from 'rxjs'
import { mapTo } from 'rxjs/operators'
getPostOne$ = timer(3000).pipe(mapTo({ id: 1 }));
getPostTwo$ = timer(1000).pipe(mapTo({ id: 2 }));
concat(getPostOne$, getPostTwo$).subscribe(res => console.log(res));
您可以阅读有关可管道运算符的更多信息 Here
希望这有帮助!
关于javascript - 转换 RxJS 5 Rx.Observable.timer(3000).mapTo({ id : 1 }) to RxJS 6?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51868852/
尝试建立一些东西,但卡住了,错过了这里的任何错误。我想跟踪按钮点击,但从 #zip 输入中获取值,所以这就是我选择 mapTo 的原因。当我删除 mapTo 时,我可以跟踪点击并更改我在订阅函数中的语
我正在阅读 Akka Futures Guide我看到这句话: Also note that the Future returned by an Actor is a Future[Any] sinc
我要映射 Map至Map但我无法在 map 函数中返回 Map.Entry: itemsWithQuantity.mapTo(mutableMapOf(), { it.key.toString() t
之前我使用的是这段代码: private val mItems = ArrayList() (1..item_count).mapTo(mItems) { it } /* mItems will b
已结束。此问题正在寻求书籍、工具、软件库等的推荐。它不满足Stack Overflow guidelines 。目前不接受答案。 我们不允许提出寻求书籍、工具、软件库等推荐的问题。您可以编辑问题,以便
背景 我正在尝试使用 go-fed 的 apcore构建联合应用程序的框架。我已经实现了 apcore.Application 接口(interface),但在加载配置时卡住了。 当尝试将从 conf
我发现了一段我看不懂的代码。 我正在将 JSONArray 转换为 List。 Kotlin 在其 stdlib( link ) 中提供了函数 mapTo mapTo inline fun > Ite
试图了解 kotlin 中 map 和 mapTo 之间的区别。谁能帮我解释一下使用一些例子的区别 最佳答案 map 在内部创建一个新列表,并将其结果放入该列表,然后返回该列表: val mapRes
function c() { return Math.random(); } source$.pipe( map(a => c()) ).subscribe(v => c
我最近开始使用 Akka/Scala 进行编码,遇到了以下问题: 在范围内进行隐式转换,例如: implicit def convertTypeAtoTypeX(a: TypeA): TypeX =
在将相同的具体类注册到不同的未命名实例时,我们看到 Unity 出现意外行为。在这种情况下,注册似乎以意想不到的方式相互干扰。 我们为我们想要注入(inject)的其他应用程序提供了一个框架不同的界面
我们如何转换: Rx.Observable.timer(3000).mapTo({ id: 1 }) 到 RxJS 6? 例如,如果我们: import { Observable, timer }
我是一名优秀的程序员,十分优秀!