Rxjava最短时间执行？

我有一个Observable A和一个Observable B.现在我必须等待那些Observable完成或至少30秒。我如何在RxJava上实现这一点？Rxjava最短时间执行？

感谢您的任何建议！

2015-08-22 Thanh Le

任何代码，您是否可以提供？ –

感谢您询问代码，但我认为我的问题不需要任何代码来澄清。例如Observable A只有一个项目，我想等到A发出这个项目或至少30秒。谢谢！ –

你是说最大时间？你能编辑你的问题来反映这个，包括标题吗？ –

你还没说你想要的a的排放，并从等待b开竣工完成的事，但你可以这样做：

Observable.merge(
    Observable.timer(30, TimeUnit.SECONDS) 
     .ignoreElements().cast(Object.class), 
    a.ignoreElements().cast(Object.class), 
    b.ignoreElements().cast(Object.class));

来源

2015-08-23 02:21:28

感谢您的回答，但我真的很想等待至少30秒。就像我想在启动画面中使用一样。 –

感谢您的回答，当我回到我的电脑时，我会检查它。 –

感谢您的回答，除了我不使用cast（Object.class）（它是cast但不castAs） –

Rxjava最短时间执行？

回答

相关问题