특정 항목이나 연속된 항목들을 반복적으로 배출하는 Observable을 생성한다
이 연산자는 반복적인 작업을 처리할 때 유용하다.
사용법은 observable.repeat(n)
repeat 파라미터안에 n번 만큼 반복할 숫자를 넣어주면 됩니다.
observable.repeat(n)
fun main() {
repeatOperator().subscribe(
{
println("rangeOperator :onNext : $it")
},
{
println("rangeOperator :onError ${it}")
},
{
println("rangeOperator :onComplete")
}
).let { _ -> }
}
fun repeatOperator(): Observable<Int> {
return Observable.range(1, 5).repeat(2)
}
출력결과
rangeOperator :onNext : 1
rangeOperator :onNext : 2
rangeOperator :onNext : 3
rangeOperator :onNext : 4
rangeOperator :onNext : 5
rangeOperator :onNext : 1
rangeOperator :onNext : 2
rangeOperator :onNext : 3
rangeOperator :onNext : 4
rangeOperator :onNext : 5
rangeOperator :onComplete