如何向Observable.interval()添加延迟？
要向Observable.interval()添加延迟，可以使用操作符delay()来实现。
delay()操作符会延迟Observable发射的每个数据项的发送时间，从而实现延迟效果。可以通过指定一个时间段来设置延迟的时长。
以下是一个示例代码：
import io.reactivex.Observable;
import java.util.concurrent.TimeUnit;
public class DelayExample {
public static void main(String[] args) {
Observable.interval(1, TimeUnit.SECONDS)
.delay(5, TimeUnit.SECONDS)
.subscribe(System.out::println);
// 等待一段时间，以便观察结果
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}在上述示例中，Observable.interval(1, TimeUnit.SECONDS)会每隔1秒发射一个递增的数字。通过delay(5, TimeUnit.SECONDS)，我们将发射的数据项延迟5秒后再进行订阅。
输出结果如下：
5
6
7
8
...在这个例子中，前5个数据项被延迟了5秒后才被订阅和输出。
延迟操作符delay()可以用于各种场景，例如在处理网络请求时，可以使用delay()来模拟网络延迟，以测试应用程序的响应性能。
腾讯云相关产品中，可以使用腾讯云函数（SCF）来实现类似的延迟效果。腾讯云函数是一种无服务器计算服务，可以在云端运行代码，支持多种编程语言。您可以使用腾讯云函数来编写延迟处理逻辑，并与其他腾讯云产品进行集成。
更多关于腾讯云函数的信息，请参考腾讯云函数产品介绍：腾讯云函数
相关·内容
1回答
我想从列表中发出项目，并在每一个排放之间延迟。我试过这个：
final Subscription subscription = Observable.from(listOfItems)
.delay(2000, TimeUnit.MILLISECONDS)
.subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwab
浏览 2提问于2016-06-24得票数 2
回答已采纳
2回答
如何在Angular2中重写并在angular1中Dart这段代码：
$interval(function () {
if($scope.carouselIndex < $scope.showcases.length -1){
$scope.carouselIndex = $scope.carouselIndex + 1;
} else {
$scope.carouselIndex = 0;
}
}, properties.delay);
我尝试过这种方式，但不起作用：
carouselIndex = 0;
fo
浏览 3提问于2016-04-04得票数 1
1回答
我试图添加使用RxJava发出的列表项的动态内部。
目前，在我的流程中，每隔10秒我就会发出这些项目，但我试图实现的是，在发出第一个项目之后，会有60秒的延迟，而其余的项目将在10秒的延迟之后继续进行。
项目#1发出60秒项目#1发出10秒延迟>H 110</代码>项目2发出<代码>H 211</代码><代码>H 112</代码>10秒延迟等等<代码>H 213/代码><代码>G 214</代码>
我的当前代码如下
.flatMap(dataList -> Observable.f
浏览 6提问于2022-01-31得票数 1
回答已采纳
Observable.interval(10000)
.switchMap(() => this.http.get(url))
.catch (err => Observable.empty())
.subscribe(data => render(data)) 每10秒我们进行一次HTTP调用。如果发生错误，observable将被完成，它不再进行任何调用。如何防止这种情况发生？
浏览 53提问于2017-08-16得票数 2
回答已采纳
1回答
我有这样一部史诗：
export const fetchCharacter = (id) =>
ajax({ url: `https://swapi.co/api/people/${id}` })
.map(response => fetchCharacterSuccess(response.body))
.catch(error => Observable.of(fetchCharacterFailure(error.response.body)));
export const startFetchingCharacters = () => ({
浏览 0提问于2017-11-12得票数 1
回答已采纳
1回答
对RxJava2来说有点陌生，我在timer和combineLatest上遇到了一些问题，例如：
Observable.combineLatest(
Observable.timer(5, TimeUnit.SECONDS).map { TimedData(it) },
locationDataSource.listen(),
sensorDataSource.listen().
Function3 { timedData, location, sensorEvent -> Combined(timedData, location, sensorEvent) }
).su
浏览 3提问于2017-03-31得票数 4
回答已采纳
4回答
[这个问题是关于的]
工作固定延迟
var frequency = TimeSpan.FromMinutes(5);
Result.Delay(frequency).Subscribe(i => Debug.WriteLine("After Fixed Delay"));
变时延伪码
Result.Delay(GetAsymptotingTime()).Subscribe(i => Debug.WriteLine("After Changing Delay"));
虽然变量延迟的代码只编译一次，但只提供第一个值(本质上是一个固定值)。
您如何订阅
浏览 2提问于2012-04-09得票数 3
回答已采纳
1回答
我正在做这样的事情：
return Observable.zip(
Observable.interval(0, MOVE_LENGTH_IN_MILLIS, TimeUnit.MILLISECONDS),
Observable.fromIterable(mySuperNiceArrayList),
new BiFunction<Long, ItemTest, ItemTest>() {
@Override
public ItemTest apply(@NonNull Long aLong, @NonN
浏览 2提问于2017-03-28得票数 3
回答已采纳
1回答
我希望发出具有指定延迟的项，重复地从数组中发出。
Observable.from(saverFileNameList)
.subscribeOn(AndroidSchedulers.mainThread())
.flatMap(urlString -> Observable.just(urlString)
.delay(5000, TimeUnit.MILLISECONDS)
.observeOn(AndroidSched
浏览 0提问于2015-11-25得票数 0
回答已采纳
我认识delay()和repeat()操作符，并且读过。
但是，我希望第一个事件立即被触发，而不是等待X分钟。
当用户单击一个按钮，不得不等待X分钟才能看到结果时，这会很奇怪，对吧？
我想做一些像doSomeTask().nowAndEveryXMinAfter()这样的事情。
doSomeTask：
Observable<Integer> doSomeTask() {
}
浏览 0提问于2018-06-26得票数 0
回答已采纳
1回答
RxJava:范围运算符不起作用
、、、、
出于实际目的，我创建了stream/Observable，它以1秒的周期发射值，它的发射值以1秒为间隔，但它在发射6秒后不终止/停止，它继续发射值。
Observable myObservable = Observable.range(1, 6)
.interval(5000, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread());
浏览 0提问于2017-10-17得票数 0
我试图为下面的代码块编写单元测试：
Observable.interval(INITIAL_DELAY, REFRESH_PERIOD, TimeUnit.SECONDS)
.flatMap {thisMethodReturnsAnObservable()}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(this::onDataLoaded, this::onError)
浏览 0提问于2019-05-15得票数 0
回答已采纳
我想学习如何使用RX的.delay()和.timer()。
fun main(args: Array<String>) {
showTime()
.delay(2, TimeUnit.SECONDS)
.andThen(showTime())
.subscribe()
}
private fun showTime(): Completable =
Completable.fromAction {
val time = Instant.ofEpochMilli(System.currentTimeMil
浏览 5提问于2018-07-25得票数 0
回答已采纳
1回答
我试图跳过流中的项目直到n秒钟，然后取下流中传递的最后一项。到目前为止，这就是我所拥有的：
const delayedState$ = state$.delay(1000);
state$.buffer(
delayedState$
).filter(
(buffer) => buffer && buffer.length > 0
).publishReplay(1).refCount().map(
(buffer) => buffer.slice(-1).pop()
).subscribe((state) => {
saveStat
浏览 0提问于2016-10-28得票数 1
我面临着下一种情况。我用onHadleIntent方法启动我的代码，部分代码在IntentService线程中工作，但是getInfoAboutUser()中的Observable.zip方法在RxJava线程中工作。
@Override
protected void onHandleIntent(@Nullable Intent intent) {
LOG.debug(Thread.currentThread().getName());
Call<String> call= mRepository.getInfo();
try {
浏览 1提问于2018-01-20得票数 1
回答已采纳
所以我试图创建一个定期触发的可观察对象，但由于某些我不能理解的原因，它只触发一次。有没有人看到我做错了什么？
Observable<Long> observable = Observable.timer(delay, TimeUnit.SECONDS, Schedulers.io());
subscription = observable
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
浏览 0提问于2015-09-11得票数 36
回答已采纳
我正在运行这段代码：
private void concatenatedSets() {
Observable<String> concatenatedSets =
Observable.just("1/5/8", "1/9/11/58/16/", "9/15/56/49/21");
concatenatedSets.flatMap(s -> Observable.from(s.split("/")))
.map(s -> Integer.v
浏览 5提问于2016-08-08得票数 0
回答已采纳
我必须重复调度相同的observable，以获得N次数，在每个observable之间间隔M秒。
O1____1sec____O2____1sec____O3____1sec____O4(completed)
注意从开始到结束之间没有任何延迟，
Observable<Precious> result = <~> // hidden for brevity (it's just a long time consuming observable that can take suppose up to 10 seconds or more)
Observable.t
浏览 4提问于2016-11-20得票数 0
我使用IntervalObservable对应用程序的服务器端进行连续调用。我可以订阅和取消订阅Oberservable，一切都正常，只有一个例外：
对服务器的第一次调用被延迟，但我希望它是即时的。IntervalObservable的行为原则上是正确的，但不符合我的要求。
@Injectable()
export class LoggerService {
constructor(private http: Http) { }
private apiURL = 'assets/file.json';
getList() {
return Inte
浏览 10提问于2016-10-12得票数 5
回答已采纳
2回答
有时，我不得不安排一些任务，并希望有自己的可重用调度程序。因为我喜欢Rx，所以我把它建在上面。
后续
有一个更新版本 of Scheduler。
Scheduler类非常简单。它得到了旧CronExpression的更新实现的支持。
目前只有这两种方法。工厂方法Create创建了一个新的调度程序，该调度器按指定的时间间隔运行，并以DateTimes的形式向观察者提供调度。
作业是用Schedule扩展排定的。这一项需要一个cron表达式和执行操作。
public static class Scheduler
{
public static IObservable Create(Time
浏览 0提问于2018-04-13得票数 5
回答已采纳
1回答
我在全局范围内有一个变量，我需要定期检查它的变化。这就是我在简单的JS中所做的事情：
let currentValue, oldValue;
setInterval(()=>{
if(currentValue != oldValue){
doSomething();
}
}, 1000)
它是如何使用Observables完成的
浏览 1提问于2017-01-27得票数 7
回答已采纳
请参阅以下kotlin代码：
class MainActivity : AppCompatActivity() {
override fun onCreate(savedInstanceState: Bundle?) {
val disposable = Observable.interval(1, TimeUnit.SECONDS, AndroidSchedulers.mainThread())
.subscribe { textView.text = it.toString }
}
}
在这里
浏览 1提问于2017-09-06得票数 0
2回答
延迟条件
、、
这里有一个代码：
someObservable.Select(x => getY(x));
Y getY(X x)
{
if (x.Value == X.ABC)
return new Y(1);
else
return new Y(2);
}
在某些情况下，我需要在一段时间后再次检查x.Value。最简单也是最糟糕的解决方案是使用Thread.Sleep：
Y getY(X x)
{
if (x.Value == X.ABC)
return new Y(1);
else
if (x.SomethingElse == true)
{
浏览 0提问于2016-12-03得票数 1
1回答
在我的Ionic 2项目中，我在provider类中每1分钟从服务器下载一次数据，每当有新数据到来时，我需要刷新页面类中的图表，我如何使用可观察性来实现这一点？这是代码在简化版本中的样子：
let startTime = new Date(Math.ceil(new Date().getTime() / 60000) * 60000);
this.Source = Rx.Observable.timer(startTime, 60000).timeInterval().pluck('interval');
this.Subscription = this.Source
浏览 1提问于2017-08-09得票数 0
如何在onNext方法调用之间造成延迟？我有个密码：
Observable<Integer> obs = Observable.range(1, 1000)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
subs = obs.subscribe(new Subscriber<Integer>() {
@Override
浏览 0提问于2016-02-23得票数 4
回答已采纳
在android中，我使用计时器执行每5秒重复一次的任务，并在1秒后以这种方式启动任务：
Timer timer = new Timer();
timer.scheduleAtFixedRate(new TimerTask() {
@Override
public void run() {
// Here is the repeated task
}
}, /*Start after*/1000, /*Repeats every*/5000);
// here i stop the tim
浏览 4提问于2016-07-27得票数 24
回答已采纳
15回答
我正在努力实现一些我认为在Rx中相当简单的东西。
我有一个项目列表，我希望每个项目都延迟发送。
似乎Rx delay()运算符只是将所有项目的发射移位指定的延迟，而不是每个单独的项目。
下面是一些测试代码。它对列表中的项目进行分组。然后，每个组都应该在发射之前应用延迟。
Observable.range(1, 5)
.groupBy(n -> n % 5)
.flatMap(g -> g.toList())
.delay(50, TimeUnit.MILLISECONDS)
.doOnNext(item -> {
System.
浏览 140提问于2015-10-23得票数 71
回答已采纳
我使用反应性扩展(Version2.1，以防万一)开始开发，对于我的示例应用程序，我需要一系列的int值，每隔1秒就推一次。
我知道，我可以用Observable.Range<int>(0,10)创建一个序列，但我不知道如何在推送之间设置相对时间。我尝试过Delay()，但在开始时只改变了一次。
然后，我找到了Observable.Generate()方法，可以在下一种方法中对此任务进行调整：
var delayed = Observable.
Generate(0, i => i <= 10, i => i + 1, i =>
浏览 0提问于2013-10-05得票数 6
1回答
我有一个翻新的观察点：
@GET("something/")
Observable<Something> getSomething();
订阅它会给出响应。
getSomething().subscribe(new Subscriber<Something>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
浏览 3提问于2016-09-04得票数 4
回答已采纳
我正在研究RxJava。我为可观察的类创建了一个真值和假值的随机布尔流。
可观察的类应该在x秒的随机持续时间( 10到90秒之间)之后被重复。在每个真值之后，我需要调用API并更新UI。
我编写了以下代码来生成随机布尔值并将它们传递给可观察到的值。但是如何在每隔x秒重复一次可观察到的结果呢？
val r = Random
val apiResultStream = Observable.create(object : Observable.OnSubscribe<Boolean> {
override fun call(subscriber:
浏览 0提问于2020-03-30得票数 0
2回答
我需要每隔1/3秒发出一次网络请求，并在onComplete方法之前等待3秒。我该怎么做？我下面的代码在发出项目前等待3秒，这不是我想要的。
disposable = Observable
.interval(0, 334, TimeUnit.MILLISECONDS)
.skipLast(9)
.take(postsCount + 9)
.subscribeWith(new DisposableObserver<Long>() {
@Overri
浏览 20提问于2017-07-23得票数 0
回答已采纳
我有以下热点可观察：
hotObservable = Observable.interval(0L, 1L, TimeUnit.SECONDS)
.map((t) -> getCurrentTimeInMillis()))
然而，我找不到一个好的方法来阻止它。我能够使用takeWhile和boolean标志(runTimer)部分解决这个问题：
Observable.interval(0L, 1L, TimeUnit.SECONDS)
.takeWhile((t) -> runTimer)
浏览 1提问于2016-12-09得票数 11
回答已采纳
帮助组合多个网络调用，并在Rxjava中积累结果。(我正在使用一个Android应用程序。)
State
-- List<City> cityList;
City
- cityId;
RestCall 1
Observable<State> stateRequest = restService.getStates();
RestCall 2
Observable<CityDetail> cityRequest = restService.getCityDetail(cityId);
在UI中，我必须在获取每个城市的所有细节之后显示城市列表，然后
浏览 4提问于2014-11-02得票数 2
回答已采纳
1回答
我有一个对象数组，我想发出每个对象，然后延迟5秒。最后，只有在发出所有对象之后，才能完成。
这是我的代码，它不能做到这一点，
public class SequentialLoopWithDelayTest {
@Test
public void test() {
System.out.println("Start: " + DateTime.now().toString());
rx.Observable.from(new String[] {"Test_1", "Test_2", "T
浏览 1提问于2016-05-13得票数 0
回答已采纳
2回答
我想实现简单的计时器，它将计数值从1到30每秒。当它达到30的时候，我希望它停止。现在我有这样的东西，但我不知道如何在30秒后停止它。
代码如下：
Observable<Long> observable = Observable.interval(1, TimeUnit.SECONDS);
observable.subscribe(
new Action1<Long>() {
@Override
public void call(Long aLong) {
浏览 1提问于2017-02-17得票数 4
1回答
我试图模拟以特定顺序发送项目时的延迟。
在这里，我试图模拟这个问题
List<Integer> integers = new ArrayList<>();
integers.add(1);
integers.add(2);
integers.add(3);
integers.add(4);
Disposable d = Observable
.just(integers)
.flatMap(integers1 -
浏览 13提问于2022-02-02得票数 0
回答已采纳
我有一个可以观察到的，obs1，它代表一个随时间变化的数字流。我需要累积这些数字的和并逐步地发出它(也就是说，我需要使用scan运算符)。
还有第二个可以观察到的，obs2，它代表某种“重置时间”。换句话说，当obs2发出时，我必须重置在obs1上设置的累加器，并从0开始求和。
我想我已经能够用下面的代码达到我想要的行为，但我不确定这是否是正确的方法(对我来说有点难闻)
const obs1 = Observable.interval(100).mapTo(1).take(100);
const obs2 = Observable.interval(700).take(10);
obs1.
浏览 0提问于2018-04-25得票数 4
3回答
你好，我每15秒向我的服务器询问它的在线/离线状态：
public Observable<Response> repeatCheckServerStatus(int intervalSec, final String path) {
return Observable.interval(intervalSec, TimeUnit.SECONDS)
.flatMap(new Func1<Long, Observable<Response>>() {
@Override
浏览 4提问于2016-01-23得票数 16
回答已采纳
1回答
在我的网站中，我使用了GTmetrix，并在以下两个文件上出现JS延迟错误。
JavaScript的92.5KiB在初始页面加载期间被解析。延迟解析JavaScript以减少页面呈现的阻塞。http://mysite.url/wp-includes/js/jquery/jquery.js?ver=1.12.4 (87.0KiB) http://mysite.url/ (内嵌JavaScript 5.5KiB)
在我的functions.php文件中，我有下面的代码来推迟js，但是对于主题文件夹之外的js文件(S)，它似乎没有受到影响。
这是我在functions.php文件中的代码
if (!
浏览 0提问于2018-12-19得票数 1
回答已采纳
1回答
如何对RX序列进行上采样(使其触发频率更高)？
.Sample运算符只允许下采样：
IObservable<long> source = Observable.Interval(TimeSpan.FromMilliseconds(5000));
IObservable<long> trigger = Observable.Interval(TimeSpan.FromMilliseconds(1000));
//var triggeredSource = source.Sample(trigger);
var triggeredSource = source.Sampl
浏览 4提问于2013-02-12得票数 1
1回答
给予：
public partial class Weather
{
private readonly DispatcherTimer _timer = new DispatcherTimer();
private readonly IWeatherDataProvider _weatherDataProvider;
public Weather(IWeatherDataProvider weatherDataProvider)
{
InitializeComponent();
_weatherDataProvider = we
浏览 1提问于2014-01-11得票数 2
回答已采纳
我在LINQPad中有了一个有趣的小扩展方法的想法，但是它让我很难理解如何去做。
基本上，我希望在任何LINQPad语句的末尾添加一个扩展方法，使该语句每隔X秒执行一次。
例如，我会这样做："Hello“.Dump().RunEvery(5)；
这将每5秒执行一次"Hello“.Dump()。其结果将是Hello每5秒向屏幕抛出一次。
我希望它足够灵活，以便在LINQPad中执行的任何语句都可以在计时器上运行。这对于我运行EventLog表的查询非常有用，因此我不必像我一样频繁地手动运行它们。我可以不停地翻回窗户，知道我看到的是最新的。
我认为这涉及到C#反射和计时器，但我很难
浏览 1提问于2015-04-30得票数 1
回答已采纳
我尝试立即运行我的任务，然后按时间间隔运行它。我写了以下内容：
var syncMailObservable = Observable.Interval(TimeSpan.FromSeconds(15));
syncMailObservable.Subscribe(s => MyTask());
问题是任务只在15秒后开始。我需要在开始时运行我的任务，然后按时间间隔继续。
我该怎么做呢？
浏览 0提问于2011-10-16得票数 8
回答已采纳
1回答
我正在做一个电影聊天，我想在我的消息中添加时间戳(#分钟前)。我听说组件文件中有大量功能是个坏主意，所以我想把它移到服务文件中。
现在，我想每60秒从服务文件中的startTimeCalculations函数返回数据到我的组件，但是我不知道如何做到这一点？有谁可以帮我？
this.messages[index].minutesAgo = this.movieChatService.startTimeCalculations(index);组件文件:在这里，我连接到行上的函数，目标是更改minutesAgo属性，但我不知道如何从服务文件中的函数中接收数据
ngOnInit(){
浏览 0提问于2018-02-22得票数 0
回答已采纳
我正在创建一个Ngrx角2应用程序，并试图让我的http调用继续轮询一个时间间隔。我已经看到了interval()函数的使用，但是在Ngrx的情况下，当服务调用在@Effect()中完成时，它会产生一个错误。请告知：
@Injectable()
export class TasksEffects {
constructor(
private actions$: Actions,
private TS: TaskService
){}
@Effect()
onLoadTasksLoadTasks$: Observable<Action> = this.actions
浏览 6提问于2017-04-01得票数 6
回答已采纳
1回答
我是个新手，一个人处理不了这件事。我有一种方法，其中一些API数据存储在一个可观察的地方，我试图每60秒触发一次这个事件。我这么做是因为我想向recyclerView提供实际数据。如果来自API的新数据已经到达，则recyclewView应该刷新。
这是从API获取数据的方法：
fun getHead(status : String , wenr : Long, test : Boolean) {
view.onShowDialog("")
val headResponseObservable: Observable<List<WeK
浏览 1提问于2019-10-11得票数 1
回答已采纳
1回答
在rxJava 1.x中，可以这样做：
Observable.<Foo>create(subscriber -> {
...
getNewObservable().subscribe(Subscribers.wrap(subscriber));
})
GetNewObservable()还返回Observable<Foo>
我在rxJava 2中找不到相同的方法。在可观测对象上没有接受发射器或ObservableEmitter的订阅方法。我想我可以这样做：
Observable.<Foo>create((ObservableEmitte
浏览 2提问于2017-04-10得票数 2
回答已采纳
我有和异步加载方法，它是由可观察的订阅触发的。
我希望使用以下策略防止LoadAsync并发调用：
我几乎肯定这个策略有个名字，但我想不起来了。
如果以前的调用尚未完成，则不会调用LoadAsync。
- _LoadAsync(3) has started only after LoadAsync(1) has finished_
LoadAsync只为最近的值调用。
- _LoadAsync(2) has never been called_
我目前使用此开关映射等效，但它取消LoadAsync方法，以支持新的调用。
Observable<int> sourceObs
浏览 1提问于2021-05-06得票数 1
回答已采纳
1回答
可观察到的Seq
、、
我使用Mongo-Scala-Driver1.0.1，它在insertMany之后返回insertMany。
我把许多文件放在循环中，在所有这些文件都插入之后，我需要采取一些行动。
我可以使用observable.toFuture获取Seq[FutureCompleted]，然后使用Future.sequence(.)来处理未来。
但是，在Scala中是否有可能将Seq[Observable[Completed]]转换为Observable[...]？还是有更好的方法来处理它？
mongo驱动程序有它自己的可观察特性org.mongodb.scala.Observable
浏览 3提问于2016-06-08得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
