共享可观测性和startWith算子

文章/答案/技术大牛

发布

1回答

rxjs、rxjs5

我有一个关于多播可观察性和我注意到的(对我来说)意想不到的行为的问题。}); console.log(`Pairwise Sub: (${prevA}, ${curA})`);因此，有一个共享的观察值由于-1 \f25 startWith -1\f6运算符而发出。可观测值b只是通过将来自a的最新两个值配对来创建新的可观测值。现在，我知道我可以在不使用startWith操作符的情况下通过Behaviou

浏览 26提问于2017-02-03得票数 8

1回答

使用反应性扩展定期保存更改

angular、rxjs、reactivex

订阅该Subject，通过以下管道运行它： import { Subject } from 'rxjs/Subject'; interval(7000).pipe(

浏览 0提问于2018-06-21得票数 0

回答已采纳

1回答

带可观测值的AngularFire2不能捕获$ref属性

javascript、angular、firebase-realtime-database、rxjs、angularfire2

因此，我开始使用AngularFire2 (Version4.0.0-rc.1)并解决了这个问题： return <FirebaseListObservable<{}>>this.store.select(getFirebaseUID) .map(res => res.UserUUID) .switchMap(uid => this.

浏览 3提问于2017-06-18得票数 1

回答已采纳

1回答

如何将两个热门的可观测<int>-s组合起来，从而得到其他值的减和之和？

c#、system.reactive、reactive-programming、observable

我有两个整数的热观测值。我想将两者结合到一个结果中，每次一个新值从任何一个可观测值中输入时，它总是用新和通知观察者。., 1, 3, 2 --->.........................

浏览 2提问于2013-09-12得票数 0

回答已采纳

2回答

发出可观测值并在组件中处理它。

angular、rxjs、observable、angular-observable

我有一个login()方法，一个AuthService。我想要的是从AuthService中的AuthService方法发出值，以处理NavbarComponent中的值。 user: AppUser = {id: null}; return this.http .post('/auth/login')

浏览 0提问于2020-01-07得票数 0

回答已采纳

1回答

RxJS扫描与组合行为

javascript、reactive-programming、rxjs

我一直在学习RxJs，我遇到了一些问题，试图确定我在使用扫描和组合时看到的输出背后的逻辑。return function(v) { }; .startWith, view2 StartWith, LOG: view1 StartWith stream, view2 StartWith, LO

浏览 0提问于2015-09-01得票数 3

3回答

在rxjs中，Observable.lift和Observable.pipe有什么区别？

javascript、angular、rxjs

将Observable.lift(operator: Operator)定义为： timesByTwoLift.subscribe(a => console.log('lift:' + a)); 和Times

浏览 0提问于2018-02-22得票数 20

1回答

RxJS:可重复的可观测值竞赛

rxjs、rxjs6

我想为文本区域中的选择打开一个上下文菜单，其中包含两个独立的交互流：如您所见，这两个流在"Selection“部分中重叠，但第一个和最后一个条件不同两者都被定义为在其结束条件下完成的单独的可观测值。从技术上讲，这就是我想要的(在考虑下一个之前，遵循一个可观察到的，直到结束)，但是那些不需要列出一个可观察的列表，而是一个发射

浏览 3提问于2020-07-27得票数 1

回答已采纳

3回答

RxJS:接受自己的旧值作为输入的可观察对象

javascript、rxjs、reactivex

c and m are some Observables. rxjs.operators.sample(c), map(([mValue, oldAValue]) => { }), rxjs.operators.startWith这有点像在a上调用pairwise，除了我不想要最后两个值，而是最

浏览 41提问于2019-09-22得票数 5

回答已采纳

1回答

参考-这个符号在C#中意味着什么？

c#、syntax、symbols

因此，在搜索运算符和其他语法标记时，很难找到许多问题。这也使得关闭副本变得更加困难。下面的清单是为了帮助解决这个问题。此外，这是 (和、等)的一个明显的副本。我们需要一个C#的。，请帮忙。编辑并添加指向其他运算符/语法引用的链接，或者如果在特定语法上找不到好的问题/答案，请添加这个问题的答案并将其链接为。

浏览 7提问于2022-03-29得票数 1

1回答

当类型参数是协变量时，F#处理继承的方式是否与C#不同？

f#、c#-to-f#

所以也许写作能帮我和其他人..。没有过载匹配的方法‘开关’。错误可能的重载：‘(扩展)TSource able.Switch<’TSource>()：I观测性<‘TSource>’。类型约束不匹配。类型<IConnectableObservable<‘b>与类型<I观测性<’a>不兼容，类型‘I观测性<

浏览 1提问于2014-10-27得票数 2

回答已采纳

1回答

可观测的startWith不会在doOnNext中发出

android、rx-java

onErrorReturn { NetworkState.Error(it) } .startWith这很好，但是我注意到，当我调用startWith和加载状态时，它从来没有被doOnNext()处理过。换句话说，从未为我的加载状态调用publishState()。在设置可观测值的地方，我不需要添加订阅服务器，因为上面的doOnNext()是我需要的全部： val subscription = repository.

浏览 0提问于2018-03-26得票数 1

回答已采纳

1回答

将本地文件与远程文件进行连接

bash、macos、ssh

server.com:~/remote.txt 我研究了以下几种可能性：命令sed 我还考虑将local.txt放在一个公开可访问的位置，例如，使用一个公共dropbox链接。

浏览 1提问于2016-12-22得票数 1

回答已采纳

1回答

基于角异步管道的全无功数据刷新

angular、asynchronous、rxjs、observable

花了很长时间寻找/研究，但只想出复杂和复杂的解决方案，需要主体或行为主体或管道通过mergeMap等。将其与使用平坦运算符SwitchMap的高阶可观测性结合起来。这将否定在类型记录中使用onCLick方法的必要性。您知道，这个主题还有更多的内容，一种真正的反应性方法可能会开始您的思考过程，即使用基于subjects/behavioursubjects/异步主题等的共享、可注入的单例服务和订阅。不过，这些都是架构和

浏览 1提问于2020-07-10得票数 13

回答已采纳

1回答

嵌套受抚养人订阅

rxjs、rxjs-observables

我正试着用可观察的方法把我的头绕过去。但我在挣扎。我已经在谷歌上搜索了一段时间了，我真的无法确定我看到的例子是否能做到我想做的事情。我有一个http端点，我向它发布了一个JSON对象。后端存储它，并使用id返回持久化对象。然后，根据我在这里得到的响应，我需要通过调用http端点2号来更新对象。service1.create(theNewObject).subscribe(response => { service2.update(response

浏览 1提问于2020-02-26得票数 0

回答已采纳

2回答

RxJS管法利用

angular、rxjs、reactive-programming

const apiData = ajax('/api/data').pipe( map(res => { throw new Error('Value expected!'); return res.response; catchError(err => of([]))我正在学习角和角的官方网站，我看到了这个代码。.pipe()函数用于什么？

浏览 1提问于2020-04-05得票数 1

2回答

RxJS共享与shareReplay差异

javascript、rxjs

似乎有一个奇怪的差异，如何共享和shareReplay (使用refcount:true)取消订阅。在timeoutWith可以重新订阅之前，共享似乎是从源代码中取消订阅的，而shareReplay则设法将共享订阅保持足够长的时间，使其能够被重用。我想使用它在RPC上添加本地超时(同时保持调用处于打开状态)，而任何重新订阅都将是灾难性的，因此希望避免以下风险--这些行为中的一个是错误的，在将来会发生更改。我可以使用race()，并将rpc调用与延迟的startsWith合并(因此它们同时订阅)，但这将是更

浏览 11提问于2022-02-15得票数 2

回答已采纳

1回答

RxSwift，如何应用背压来连续显示流中每个项目的UIAlertView

ios、reactive-programming、rx-swift

我有一个Observable<Item>，它异步地发出一系列项。对于流中的每一项，我需要显示一个UIAlertView。每次用户解除警报(如果有一个新的项目)，我需要抓住下一个项目，并为它显示一个新的警报。流可能在一秒钟内产生10个项目，我想显示10个弹出窗口，这些弹出窗口将依次打开，一次一项，一个接一个。

浏览 1提问于2017-11-14得票数 1

回答已采纳

1回答

使用“`replay`”和“`autoConnect`”时出现的“比请求更多的”异常

java、rx-java、reactive-programming

我想要创建一个可观察的，它只在新值与前一个值不同的情况下，从底层的热可观测(从之前的-1开始)发出值。此外，我希望立即向新订阅者发出最新的值。> hotObservable = PublishSubject.create(); .startWithmore produced than requested的新订阅服务器之后，这会失败： Observable<Integer> observable = hotObserva

浏览 5提问于2016-04-11得票数 0

回答已采纳

2回答

将IObservable<IEnumerable<T>>转换为IEnumerable<IObservable<T>>

c#、linq、system.reactive

如何将可枚举xys的可观测性转换为可观测yxs的枚举，其中yxs的每个可观测到的集中在xys的每个时间步骤的特定元素上？我想要的类似于可枚举的可枚举项的换位。和上面的例子一样，无限可观测值应该是可能的，也应该是无限可枚举的。

浏览 4提问于2014-08-23得票数 3

回答已采纳

点击加载更多