我有并且观察到，如果onNext是由函数返回的，它永远不会发送它，但是如果我在返回它的函数中订阅它，onNext就会被调用。static func registerPushToken(_ pushToken: String) -> Observable<Result<User>> { }
浏览 1提问于2017-01-03得票数 1
回答已采纳
我想通过网络发送多个请求，这个帮助了我，但我仍然停留在后面的部分。看来我应该从onSubscribe，onNext，.返回一个值(OnNext).因为apply函数返回一个值。但是.，默认情况下，onNext返回无效。有什么帮助吗?这是我的代码
浏览 2提问于2017-04-11得票数 0
回答已采纳
我正在使用DispatchGroup从3个不同的API下载数据，一旦完成，我想从我的函数中返回新创建的合并对象。现在，尽管DispatchGroup运行良好，并且我正在获取数据，但我无法将其返回到调用函数。下面是我的函数： return
浏览 0提问于2018-05-06得票数 2
我无法理解RxSwift中的map和flatMap之间的区别。在RxSwift操场的例子和书籍中，flatMap被用来转换具有内部可观测性的可观测对象。然而，我看到flatMap被直接用于基本类型的Observable。例如，对于下面的代码，它们都会产生相同的输出。有人能帮我理解一下map和flatMap之间的区别吗？: {})
let deneme2 =
浏览 0提问于2018-04-03得票数 12
回答已采纳
，成功时应返回true，出现错误时应返回false： if= null) { @OverridefeedEntity) {
浏览 1提问于2015-12-22得票数 2
回答已采纳
我已经创建了一个简单的方法，它将发送消息(作为对象)给给定的主题。在另一端，订阅服务器将使用该对象。 subject.onNext(object); });上述方法如下所示(从Android活动中，目标是将项发送到主题将通过方法中的
浏览 5提问于2017-01-15得票数 3
回答已采纳
我试图弄清楚如何在FSharp.Control.Reactive库中使用Observable.create函数，但似乎遗漏了一些东西。函数签名定义为：我尝试了几种不同的创建可观察对象的方法，例如：
Observable.createOnNext，因此不会调用subscribe中的p
浏览 0提问于2015-04-04得票数 3
如果没有交互，BLE设备的超时时间为5分钟。也就是说，如果没有读写操作5分钟，设备将自动断开连接。当超时断开发生时，我将得到BleGattException。rx.internal.util.SubscriptionList.unsubscribe(SubscriptionList.java:125) W
浏览 7提问于2017-04-21得票数 0
2回答
我想使用Subject使用默认值来发送值。不幸的是，startWIth返回Observable，因此我不能使用onNext()，这是我最初使用Subject的唯一原因。此问题的解决方法是什么？
subject.onNext("n
浏览 0提问于2017-10-12得票数 1
2回答
我需要通过一个主题代理所有不同的事件流。') { }
return Rx.Observable.throw(x.Data);
return Rx.Observable.empty，一旦出现错误，就会调
浏览 5提问于2012-03-06得票数 0
回答已采纳
我有点不熟悉观察，所以我只是在寻找一个例子，这将使我在正确的方向(也许教程？)所以这就是-我想要创建异步Observable并利用它创建一个Exception。以下是我的例子： return Observable.Start<Tuple<DataPart1, DataPart2>>((
浏览 3提问于2012-08-08得票数 1
回答已采纳
2回答
可观测到的扁平的
、、、
我想做的是创建一个函数，它每秒钟运行另一个函数。第二个函数返回Observables<A>，我希望第一个函数也返回Observables<A>，而不是Observable<Observable<A>>private A calcA(){do { } while (conditi
浏览 0提问于2018-04-19得票数 0
回答已采纳
2回答
我有一个向服务器发送API请求的函数。我想循环它，直到它返回false (不再有数据)。func getData(id: Int) -> Observable<Bool> { //它只迭代我的函数1x。
第二次尝试:使用范围。这里的问题是，即使我的getData<em
浏览 0提问于2018-03-29得票数 2
回答已采纳
1回答
我有两个Observable序列，即Observable1和Observable2。它们都是在独立的调度程序上执行的。Observable1从数据库获取数据，而Observable2从服务器获取相同的数据。
这两个Observable序列的结果使用主题发送到Observer。现在，如果没有互联网连接，那么Observable2会在Obse
浏览 5提问于2016-09-06得票数 0
我有两个问题：
var index: Int?var osInfo: Observable<StringA和b的区别是什么？a. var osInfo: Observable<
浏览 0提问于2019-03-22得票数 15
回答已采纳
我有一个返回可观察值的方法。private func getWifiConfig() -> Observable<String?.flatMap { $0.discoverCharacteristics([ strongSelf.wifiCharacteristicUUID ])}
.flatMap { Observ
浏览 1提问于2017-04-22得票数 1
3回答
依次执行单独的可观察性
、、、、
我正试图实现我的可观察性，只有在以前的可观测性已经完成时才能执行。我不能使用flatMap，因为订阅可以从不同的地方调用，而且这些可观察到的内容并不是相互连接的。具体来说:我的CollectionView从服务器加载更多的内容，在用户单击“发送评论”按钮2秒后，CollectionView仍在加载它的批处理。.enqueue(observable1)
.subscribe(
浏览 0提问于2018-09-28得票数 6
回答已采纳
我想知道是否有可能在每次可观察到的滴答时启动一个任务，并使用这些任务的结果继续流水线。结果的顺序并不重要。我正在使用C#。上面的代码将启动下载urls的任务，但如何获得可用的结果(即downloadTask已完成)。另一个考虑因素是来自任务的Exceptions。任何异常都不应影响其余任务。
浏览 11提问于2019-03-11得票数 0
回答已采纳
1回答
我正在学习以正确的方式在.NET中执行rx，并且想知道从远程函数调用中生成可观察的流的通常方法是什么。{}
这就是我在回调方法中调用<e
浏览 11提问于2018-08-23得票数 0
回答已采纳
@Override return "result"; } return Observable.fromIterableLOG: onNext: result
LOG: onNext: res
浏览 4提问于2018-11-22得票数 3
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号