如何创建无限间隔的Observable，它将在每个时间间隔发出新的Object? [英] How to create infinite interval Observable that will emit new Object every time interval?

问题描述

我正在尝试创建一个Observable，它将每秒发出一个新对象. 所以现在我只压缩一个Observable，它从列表中发射有限数量的对象，间隔为Observable.

I am trying to create an Observable that will emit new object every second. So for now i am just zipping one Observable, which emits finite number of objects from a list, with interval Observable.

   val list1 = mutableListOf<SomeClass1>(
            SomeClass1("1", 1), SomeClass1("2", 2), SomeClass1("3", 3),
            SomeClass1("4", 4), SomeClass1("5", 5), SomeClass1("6", 6),
            SomeClass1("7", 7), SomeClass1("8", 8), SomeClass1("9", 9)
    )

    val someClass1Observable = Observable
            .fromIterable(list1)
            .zipWith(Observable.interval(2, TimeUnit.SECONDS),
                    BiFunction { item: SomeClass1, _: Long -> item })

那么，如何以每2秒就有一个带有某些参数的，名为SomeClass1类的新对象的方式实际实现此无限化?

So how to actually make this infinite, in a way that every 2 second there will be emiited new object of class SomeClass1 with some parameters?

推荐答案

以下是我的问题的答案，它满足了我的要求:

Here is the answer for my question, that satisfies my:

 override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(R.layout.activity_main)

    var counter = 0

    val periodicSomeClass1 = Observable.interval(1, TimeUnit.SECONDS)
            .flatMap(
                    {
                        counter++
                        Observable.just(SomeClass1("$counter", counter))
                    }
            )


    periodicSomeClass1.subscribe { t: SomeClass1 -> Log.v("periodicSomeClass1", t.toString())  }

}

这篇关于如何创建无限间隔的Observable，它将在每个时间间隔发出新的Object?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！