方向改变时在presenter中处理Rx Disposable的正确方法
在处理Rx Disposable时，可以采用以下正确方法：
- 首先，需要了解Rx Disposable的概念。Rx Disposable是RxJava中用于取消订阅的接口，它可以用来释放资源、取消网络请求等操作，以避免内存泄漏和不必要的计算。
- 在presenter中，应该在合适的时机创建和管理Rx Disposable对象。一般来说，可以在presenter的生命周期方法中创建Rx Disposable对象，如在onCreate()方法中创建，并在onDestroy()方法中取消订阅。
- 在创建Rx Disposable对象时，可以使用CompositeDisposable类来管理多个Disposable对象。CompositeDisposable可以将多个Disposable对象添加到一个集合中，并在需要时一次性取消订阅。
- 在合适的时机，需要调用Rx Disposable的dispose()方法来取消订阅。可以在presenter的onDestroy()方法中调用CompositeDisposable的dispose()方法来取消所有订阅。
- 正确处理Rx Disposable可以避免内存泄漏和不必要的计算，提高应用的性能和稳定性。
在腾讯云的产品中，可以使用腾讯云的云函数（SCF）来处理Rx Disposable。云函数是一种无服务器计算服务，可以帮助开发者在云端运行代码，无需关心服务器的管理和维护。通过使用云函数，可以将Rx Disposable的创建和管理交给云端，从而简化开发流程并提高应用的可靠性。
腾讯云云函数产品介绍链接地址：https://cloud.tencent.com/product/scf
相关·内容
1回答
我试图使用Rx2Animations库，但它在示例中使用Lambda变量。所以，我不太清楚如何在普通代码中扩展这个lambda。
例子：
package oxim.digital.rx2animations.colorpicker;
import java.util.concurrent.TimeUnit;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
public final class ColorPickerPresenter
浏览 0提问于2017-05-02得票数 0
回答已采纳
如何在TS文件中正确导入Disposable：
import { Disposable } from 'rxjs'
import { Disposable } from 'rxjs/Rx'
import * as Rx from 'rxjs'
然后
Rx.Disposable() or Disposable.create() etc...
这些选项都不起作用。我通常会以这样的错误结束：
Rx has no exported member 'Disposable'
我使用过这样的类型：
typings install dt~rx
浏览 3提问于2016-07-16得票数 0
这是我第一次在反应性范例世界中开发，我开始使用rxjava2 2/rxandroid2 2，因为根据我看过的视频和我读过的文章，从2开始似乎更好，因为1有如此多的变化，在很大程度上与库不同，但现在我很难找到类似于
unsubscribe()
以前的rxjava/rxandroid库的方法
我的目标很简单
执行API调用(网络操作)
倾听并对可观察到的事物做出反应(快乐之路)。
当应用程序进入暂停状态时，不要监听或作出反应
或者，在android进入暂停生命周期时，立即取消可观察到的订阅。
，根据周围的资源
dispose()
rx2方法，我所理解的是它处理任何当前资
浏览 5提问于2017-03-23得票数 1
回答已采纳
我试图用Rx方式使用room从数据库中检索数据。我就是这么做的
override fun onStart() {
super.onStart()
disposable.add(presenter.getAllBooks()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({
println(it.size())
})
浏览 3提问于2017-11-13得票数 0
回答已采纳
我有一个为RecyclerView.Adapter创建的演示者。presenter有一个调用API层的方法，然后更改一些本地数据值。这是作为Rx链实现的：
public void doStuff(Object args) {
mRemote.doStuff(args)
.doOnNext(count -> mLocal.setStuffCount(count))
.firstOrError()
.subscribeOn(mSchedulerProvider.io())
.observe
浏览 17提问于2017-03-17得票数 1
7回答
不使用订阅的结果。
、、、、
我今天升级到了AndroidStudio3.1，它似乎增加了一些皮棉检查。其中之一是检查没有存储在变量中的一次性RxJava2 subscribe()调用。例如，从“我的房间”数据库中获取所有玩家的列表：
Single.just(db)
.subscribeOn(Schedulers.io())
.subscribe(db -> db.playerDao().getAll());
结果是一个大的黄色块，这个工具提示：
不使用subscribe的结果
像这样的一次性Rx电话的最佳实践是什么？我是否应该在完成时保持Dispos
浏览 8提问于2018-03-27得票数 153
回答已采纳
1回答
rx继电器从未处理过吗？
、、、
在Rx relays上读到，它说它们从不完成或发出错误：
是否意味着除非您手动处理它们，否则它们将永远不会释放，例如：
let disposable: Disposable?
override func viewDidLoad() {
super.viewDidLoad()
disposable = viewModel.myRelay.subscribe(onNext: { //do stuff })
}
override func viewWillDisappear() {
super.viewWillDisappear()
disposable.di
浏览 7提问于2022-04-16得票数 1
回答已采纳
问题:当我试图在PullToRefresh之后立即旋转手机时，由于我在onPause中调用了dispose()方法，我的Observable将无法完成它的工作。我理解为什么会发生这种情况，但我不知道如何在不损失结果的情况下处理。如果我不调用dispose，一切都会正常工作，但我希望正确地处理Disposable，这样就不会出现内存泄漏等问题。 我的基础演示者： abstract class BasePresenter<T> {
private var view: WeakReference<T>? = null
/**
* View re
浏览 13提问于2019-01-16得票数 0
回答已采纳
2回答
在RxJava中，与观察者订阅的订阅返回可以取消订阅的订阅。
在RxJava 2中，订阅一个观察者将返回void和no Disposeable。如何才能停止这种“订阅”？
// v1
rx.Observable<Long> v1hot = rx.Observable.interval(1, TimeUnit.SECONDS);
rx.Observer<Long> v1observer = new TestSubscriber<>();
Subscription subscription = v1hot.subscribe(v1observer);
subsc
浏览 1提问于2017-01-02得票数 6
我有一个从Rx的角度可以观察到的集合，这些项目也是可观察的(从Rx的角度来看)。
我希望能够观察集合中项的属性何时发生变化，但是集合大小可以修改-添加、删除等。当发生这种情况时，我想重新订阅集合中的项的属性。
我有可以工作的代码，但我正在寻找更优雅的\声明性的东西，而不必使用主题。
private _favourites = new ObservableCollection<Favourite>();
...
public IObservable<Unit> FavouritesChanged()
{
var dispo
浏览 5提问于2017-04-30得票数 0
回答已采纳
1回答
我对Rx相当陌生，很难找到解决我的问题的方法。我正在使用Rx开始通过客户端库下载。目前看来：
private void DownloadStuff(string descriptor, Action<Stuff> stuffAction)
{
this.stuffDownloader.GetStuffObservable(descriptor).Subscribe(x => stuffAction(x))
}
其中stuffDownloader是定义在客户端库中的下载逻辑的包装器。但是我遇到了一个问题，我太频繁地调用DownloadStuff，导致了大量的下载，并淹没
浏览 5提问于2013-04-23得票数 0
我有三个按钮，我希望每次只选择一个按钮：
和：
等等。
我的方法是：
class MyController: UIViewController {
@IBOutlet var buttonOne: UIButton!
@IBOutlet var buttonTwo: UIButton!
@IBOutlet var buttonThree: UIButton!
var buttonOneIsSelected = Variable(true)
var buttonTwoIsSelected = Variable(false)
浏览 45提问于2017-02-19得票数 5
回答已采纳
我创建了test：
class MenuPresenterTest {
lateinit var presenter: MenuPresenter
lateinit var view: MenuView
@Before fun setUp() {
view = mock(MenuView::class.java)
presenter = MenuPresenter()
}
@Test fun test_validation() {
presenter.openActivity()
ve
浏览 4提问于2017-08-08得票数 0
回答已采纳
我正在努力获得一个更好的了解清理后，我创造了一个定制的可观察。为了避免内存泄漏，您应该使用一次性函数进行清理。在这种情况下，我使用的是Rx计时器方法，而不是setInterval。我认为，当我调用observer.onCompleted()时，在内部清理计时器，我的一次性操作是无用的。我对这个过程的理解是正确的吗？
function countInterval(interval, times) {
return Rx.Observable.create(function (observer) {
var timerId = Rx.Observable.timer(0, inte
浏览 7提问于2016-12-07得票数 2
回答已采纳
3回答
我正在将我的应用程序迁移到MVP。已经从这个中获得了静态演示程序模式的提示。
这是我简单的MVP策略。为了简洁起见，删除了大多数样板和MVP侦听器。这个策略帮助我改变了方向，证明了我的背景过程。与正在完成活动的停顿相比，活动正确地从正常的暂停中恢复。而且，演示者只有应用程序上下文，因此它不保留活动上下文。
我不是java专家，这是我第一次尝试MVP，使用静态演示器让我感到不舒服。我是不是遗漏了什么？我的应用程序运行得很好，反应也更快了。
视图
public class MainActivity extends Activity{
private static Presenter pre
浏览 1提问于2015-08-16得票数 6
回答已采纳
1回答
需要一个Action作为参数。在释放Rx订阅时运行Action。
在处理Rx订阅时，我想运行一些异步清理代码，但是使用async () =>和Action是完全相同的，我想避免使用async void。有关我为什么要避免这种情况的更多细节，请参见。
是否可以创建类似于Disposable.AsyncCreate的东西，它接受Func<Task>而不是Action。如果是这样的话，我应该如何使用它作为CompositeDisposable的一部分
还是有其他处理异步处理的模式？
浏览 4提问于2017-07-24得票数 6
回答已采纳
我是从Android的角度来问这个问题的，但这应该适用于RxJava。
作为一种最佳实践，我的视图是否应该始终处理即使是短暂存在的Completable、Single、Maybe和终止Observable Rx类型，这些类型应该在短时间内终止，但在用户关闭视图时可能仍在执行？我知道，当Rx链终止时，它会被释放，但这可能会在视图关闭后的某个时候发生。
例如，正在执行HTTP的Single。调用将完成，但可能是在视图被销毁后，暂时阻止垃圾收集。
如果使用一个CompositeDisposable来收集这样的Disposable，那么我认为应该注意clear()，或者定期删除这些Disposable
浏览 7提问于2017-09-27得票数 28
试图在Android上使用Dagger和Kotlin。得到了例外：
Caused by: kotlin.UninitializedPropertyAccessException: lateinit property presenter has not been initialized
at com.ad.eartquakekotlin.main.MainFragment.onViewCreated(MainFragment.kt:43)
at androidx.fragment.app.FragmentManagerImpl.moveToState(FragmentManage
浏览 0提问于2018-10-09得票数 0
回答已采纳
当我使用Observable.subscribe()时，通常返回Disposable。
但是Observable.subscribe(观察者)返回空。
所以我不能处置给Observable.subscribe(观察者)。
根据introtorx.com的说法，Observable.subscribe(Obeserver)返回Disposable。
为什么rx和rxjava不同？
++++++++++++++
我在Android Studio中使用compile 'io.reactivex.rxjava2:rxandroid:2.0.1'。
github.com/Reactive
浏览 5提问于2017-06-16得票数 6
有一个相当大的问题--有一个带有几个输入域的表单，并且想要使用RxSwift来验证这些输入域。当我编辑文本时，一切都很好，但当我想在点击按钮后验证这些字段，甚至只是将这些字段绑定到button.rx.isEnabled时，它就不起作用了，任何帮助都将不胜感激。下面的代码(混合了一些注释)： ViewController:
func setupBindings() {
self.emailInputField.inputTf
.rx.text.orEmpty
.bind(to: self.presenter.emailInputF
浏览 24提问于2020-04-06得票数 0
我正试图找出在使用自定义可观察的自定义创建的处理程序上实现dispose处理程序的“正确”方法。
返回的命名dispose函数：
Rx.Observable.create(obs => {
//emit values
obs.onComplete();
return function dispose() {
console.log('diposed');
};
});
返回的匿名函数：
Rx.Observable.create(obs => {
//emit values
obs.onComplete();
return ()
浏览 3提问于2016-08-30得票数 1
回答已采纳
我对Rx和RxPy比较陌生--有一件基本的事情我想做，那就是访问我在观察者on_completed末尾存储的值。我有一种感觉，我要么遗漏了一些非常明显的东西，要么我可能将可观察到的概念扭曲成了它不应该是的东西。不管怎样，希望我能从中得到一些指导。
我已经查看了materialize之类的文档，但它们似乎并不完全匹配。我还研究了Do和Disposable，但找不到很多接近我需要的示例。
import rx
from rx import operators as ops
from rx.core import Observer
if __name__ == "__main__":
浏览 4提问于2019-08-05得票数 0
2回答
取消订阅可观察的Rxjava
、、、、
我对Rx java observables还是个新手，所以我不确定什么时候取消订阅。这就是我的代码实现方式
Observable<String> sampleObservable = Observable.just(accountNum);
Subscription sampleSub = sampleObservable.subscribeOn(Schedulers.io()).subscribe(new Action1<String>() {
@Override
public void call(Str
浏览 0提问于2018-10-15得票数 2
我想为我的Presenter类创建一个测试，但我在Presenter内部的CompositeSubscription实例上遇到了问题。当我运行测试时，我得到了这个错误：
java.lang.NullPointerException
at rx.subscriptions.CompositeSubscription.add(CompositeSubscription.java:60)
at com.example.Presenter.addSubscription(Presenter.java:67)
at com.example.Presenter.getGummyBears(Presente
浏览 23提问于2016-09-27得票数 5
1回答
我有一个模型视图主持人三合会。我想知道测试主持人的通常方法是什么。
我首先想到的是实例化演示者并实例化一个真实的视图，然后断言视图将完成预期的行为。
public void itShouldSayHello() {
View view = new View();
Presenter presenter = new Presenter(view);
presenter.userSaid("hello");
assertTrue(view.getGreeting().equals("hello"));
}
然后我认为这个视图没有被测试
浏览 4提问于2015-05-11得票数 3
回答已采纳
有RecyclerViewAdapter，它显示项(这些项已经映射到数据库中)。
RecyclerViewAdapter包含对演示者加载项的引用。此外，它还包含带有项ID的ArrayList。
如何使用Rx加载项目？如何看待onBindViewHolder方法的正确代码？
现在看起来是：
List<Long> ItemIds;
Presenter presenter;
public void onBindViewHolder(ViewHolder holder, int position) {
Long itemId = ItemIds.get(position);
浏览 2提问于2016-10-21得票数 1
回答已采纳
这些天来，当我有一个实现IDisposable的对象时，我越来越多地试图利用using块，但我还没有弄明白如何捕获异常，就像在普通的try/ catch /最终.有什么代码样本可以指引我正确的方向吗？
编辑:这个问题是修改后，通过阅读答复。它是“如何在使用.NET 2.0的块中抛出异常？”但我实际上是在寻找一种方法来捕获在using块中出现的这些异常。
我正在寻找更多关于滚动我自己的捕获块在一个使用块中的细节。
编辑:我想要避免的是不得不在我的使用块中使用try/catch/终于，如@Blair所示。但也许这不是问题..。
编辑：@Blair，这正是我想要的，谢谢你的详细回复！
浏览 9提问于2008-08-30得票数 4
回答已采纳
我正在学习Viper w/ RxSwift。
我想通知我的Presenter，viewDidLoad在我的ViewController中被调用了。
要做到这一点，我有以下几点：
class LoginPresenter {
weak var view: LoginView?
var interactor: LoginUseCase?
var router: LoginRouter?
private(set) var viewDidLoad = PublishSubject<Void>()
private lazy var dispose
浏览 1提问于2019-09-11得票数 5
回答已采纳
我目前正在尝试根据从后端url获取的加载到表视图中的项的数量来显示和消失动态UIbutton。如果有12个或更多的项目加载到表视图中，我想按下按钮显示，如果少于12个，则不显示。有什么好的方法来处理这个问题吗？
import UIKit
import RxSwift
import RxCocoa
public class AllProvidersPickerViewController: InputableTableViewController, ViewModelHolder {
@IBOutlet private(set) weak var searchBar: UISearc
浏览 0提问于2017-05-16得票数 0
因此，我想使用rx 2进行表单验证。我在用Kotlin。我遇到了两个问题。emailObservable和passwordObservable都是Disposable!型。我试图通过调用val emailObservable: Observable<Boolean>来指定类型，但是Android认为是它的Disposable!。
其次，当我想使用combineLatest方法时，我得到了一个错误:不能用提供的参数调用以下函数。
emailObservable和passwordObservable都能正常工作。我刚接触过rx，对这种类型的东西很困惑。
val emailObserva
浏览 0提问于2018-03-15得票数 0
回答已采纳
1回答
我在我的GWT应用程序中使用MVP模式，遵循这里给出的示例
对于MainView中的每个面板，我都有一个MainPresenter和子演示者。为了显示一个新的子演示者，我这样做：
presenter = new PresenterA(new ViewA(), ....);
presenter.go(panel) // presenter clears the panel and itself to the panel
当创建PresenterA时，它将自己绑定到ViewA中的事件。我的问题是，切换到新演示者的正确方式是什么？现在，我只是创建了一个新的presenter，并将其附加到相同的面板，
浏览 1提问于2010-04-13得票数 6
回答已采纳
2回答
免责声明:这不是MVP对MVVM的帖子.
我做了一个简单的项目来了解MVP是如何工作的
我的活动
class MainActivity : AppCompatActivity(), MainContract.View {
lateinit var presenter: MainPresenter
private val counter by lazy { findViewById<TextView>(R.id.value_tv) }
override fun onCreate(savedInstanceState: Bundle?) {
浏览 10提问于2020-03-06得票数 0
回答已采纳
在我的应用程序中，我使用了从网络获取数据的web请求调用链。即从一个请求的结果，我将发送其他请求，以此类推。但是当我处理web请求时，只有父请求在处理。另外两个请求仍在运行。如何在Rx中取消所有这些请求
浏览 0提问于2012-04-25得票数 1
回答已采纳
1回答
我有PaymentPresenter和payWorkOrder()方法。该方法接受一些参数，并根据创建的两个新对象的逻辑：
WoPaymentPaymentRequest
以下是这方面的代码：
@RunWith(PowerMockRunner.class) @PrepareForTest({TextUtils.class, WoPayment.class, PaymentRequest.class})
public class PaymentPresenterTest extends BaseTest {
@Rule TrampolineSchedulerRule trampolineSch
浏览 1提问于2019-12-02得票数 0
回答已采纳
我有两个IDisposables需要按顺序处理。排序很重要，因为第一个IDisposable杀死了依赖于将被第二个IDisposable杀死的服务的Rx订阅。这是在Windows Forms应用程序中进行的，其中IObservable的订阅需要在不同的线程上进行，但观察和处理需要在UI线程上进行。(实际上，只要顺序得到保证，我并不关心是否在UI线程上进行处置。)因此，在代码中，我大致有以下内容(一旦减少)：
SomeService = new DisposableService();
Subscription = Foo(someService).SubscribeOn(NewThreadSc
浏览 1提问于2013-01-03得票数 2
我试图在android中使用MVP、RX和Dagger 2。下面是代码流，
LocalDataSource.java
@Singleton
public class LocalDataSource implements DataSource {
@Override
public Observable getServerSettings() {
return mDBHelper.createQuery(ServerSettingsEntry.TABLE_NAME,
DbUtils.getSelectAllQuery(ServerSettingsEntry.TABLE_NAME))
.mapTo
浏览 0提问于2018-08-13得票数 4
回答已采纳
1回答
我有一个安卓项目，它使用的是，它依赖于RX 2，具体来说，就是io.reactivex.rxjava2:rxjava:2.1.2。到目前为止，这并不是一个真正的问题，因为我一直无法弄清楚如何具体地取消一个。
我已经实现了
下面是我的代码：
private Flowable<Progress<FileLink>> upload;
private void myMethod(){
upload = new Client(myConfigOptionsHere)
.uploadAsync(filePath, false, storageOptions);
浏览 3提问于2019-05-31得票数 1
回答已采纳
1回答
插入另一个可观察到的
、、、
假设伪代码：
class MyActivity : Activity {
Observable<string> mainObl
void OnCreate(Bundle bundle) {
mainObl = Observable.Never<string>();
}
Disposable subscription;
void OnStart() {
subscription = mainObl.Subscribe(UpdateUiOnEvent);
}
void OnStop() {
浏览 1提问于2016-11-07得票数 0
我最近刚开始在我们的一些项目中使用完整的代码分析规则集。真正让我更仔细地思考IDisposable类的警告之一是。我有很多这样的例子，抱怨没有在每个异常路径上释放一些一次性对象。
因此，问题是:在方法的其余部分出现异常时，在返回之前处理对象处理的更正确的方法是什么？例如，这种方法：
public MyDisposable GetMyDisposable()
{
var disposable = new MyDisposable();
disposable.MethodThatCanThrowExceptions();
return disposable;
}
会引发这样
浏览 2提问于2014-08-21得票数 3
我有下面的RxJava 2代码(在Kotlin中)，它有一个可以观察到的
disposable = Observable.create<String>({
subscriber ->
try {
Thread.sleep(2000)
subscriber.onNext("Test")
subscriber.onComplete()
} catch (exception: Exception) {
浏览 4提问于2017-07-10得票数 2
回答已采纳
我对Rx很陌生，所以要忍受我自己。
我想把Task<T>包在IObservable<T>里。到目前为止还不错：
Task<T> task = Task.Factory.StartNew(...);
IObservable<T> obs = task.ToObservable();
现在，我想要的是，当观察者取消订阅时，发出取消任务的信号：
var cancel = new CancellationToken();
Task<T> task = Task.Factory.StartNew(..., cancel);
IObservab
浏览 2提问于2013-08-27得票数 2
回答已采纳
2回答
我使用RxJava 2 Observable在我的应用程序中包装条形码扫描器。这个片段展示了我如何订阅Observable并收听它的事件
override fun start() {
disposables.addAll(subscribeToBarcodeReader(), loadUser())
}
private fun subscribeToBarcodeReader(): Disposable {
return barcodeObservable
.subscribeOn(bgScheduler)
.observeOn(mainSch
浏览 0提问于2018-04-06得票数 1
回答已采纳
我的期望是即时添加可观察对象(例如:图像上传)，让它们开始，当我完成对所有内容的动态排队时，等待所有可观察对象完成。
下面是我的类：
open class InstantObservables<T> {
lazy var disposeBag = DisposeBag()
public init() { }
lazy var observables: [Observable<T>] = []
lazy var disposables: [Disposable] = []
open func enqueue(observabl
浏览 3提问于2017-07-28得票数 0
2回答
我使用System.Reactive.Linq扩展方法将可观察到的结果转换为异步方法中的结果。当我有一个对象引用时，代码将正确运行；但是，当我将null传递到OnNext方法时，生成的however抛出
System.InvalidOperationException
HResult=0x80131509
Message=Sequence contains no elements.
Source=System.Reactive
StackTrace:
at System.Reactive.Subjects.AsyncSubject`1.GetResult() in D:\a\1\s
浏览 0提问于2019-03-29得票数 0
1回答
我在流中有几个completable rx subscriptions，如下所示：
viewModel?.setupDoorMode().subscribe(onNext: { shouldConnectToDoor in
if shouldConnectToDoor {
self.viewModel?.connectAndOpenDoor().subscribe(onCompleted: {
self.viewModel?.openOrCloseDoor().subscribe().disposed(by: self.disposeBag)
浏览 65提问于2021-02-12得票数 0
回答已采纳
嗨，我试图模仿我从一个可以观察到的单个响应中得到的响应，这个响应是通过使用我的演示类调用的委托程序返回的，并且我得到了以下错误：
LoginPresenter(#1).login(LoginRequest(email=hello@gmail.com，io.mockk.MockKException: io.mockk.MockKException:找不到答案)
这是我的测试代码
@Test
fun testKotlinMock(){
val presenter : LoginPresenter = mockk<LoginPresenter>()
val d
浏览 2提问于2018-01-12得票数 35
1回答
我正在编写一个需要很长时间运行的进程，我希望优化使用过的内存
我有一个数据流，随着时间的推移，我希望有一种方法来清理这个数据和声明的变量时，流完成。有什么想法吗？
我列举了一个关于这个问题的快速例子：
var source = Rx.Observable.interval(100)
.take(20)
.map((x) => {
let onlyTrash = _.range(1000000);
浏览 3提问于2016-04-16得票数 2
回答已采纳
给出了以下设想：
一个以View和多个EditText为特色的EditText
View提供了对Observables的访问，使用如下所示的
fun observeUsername(): InitialValueObservable<CharSequence> = RxTextView.textChanges(et_username)
对于EditText(其中三个是用户名、密码和电子邮件)和
fun observeSignUpCheckBox(): InitialValueObservable<Boolean> = RxCompoundButton.checkedCh
浏览 0提问于2017-10-02得票数 1
回答已采纳
2回答
我正在开发一个服务器组件，它负责在内存中缓存模型，然后将任何更改流式传输到感兴趣的客户端。
当第一个客户端请求一个模型(模型密钥，每个模型都有一个密钥来标识它)时，模型将被创建(以及对下游系统的任何订阅)，然后发送到客户端，随后是更新流(由下游系统生成)。任何后续的客户端都应该获得这个缓存(更新)的模型，同样使用更新流。当最后一个客户端取消订阅模型时，应该销毁下游订阅，并销毁缓存的模型。
关于Rx如何在这里提供帮助，有人能给我指出正确的方向吗？我猜目前我不清楚的是我如何同步(对象的)状态和更改流？我会为模型和更新使用两个单独的IObservables吗？
更新:以下是我目前掌握的信息：
浏览 2提问于2014-07-31得票数 0
3回答
我试图用RxJava编写一个简单的程序来生成无限的自然数序列。因此，到目前为止，我发现了两种使用Observable.timer()和Observable.interval().生成数字序列的方法我不知道这些功能是否是处理这个问题的正确方法。我希望有一个简单的函数，像Java 8中的函数那样，生成无限的自然数。
IntStream.iterate(1，->值+1).forEach(System.out::println)；
我试着使用可观察到的IntStream，但这并不正确。它只向第一个订户发送无限的数字流。如何正确生成无限自然数序列？
import rx.Observable
浏览 2提问于2015-05-05得票数 8
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
