blob: b87849a5627fa76d2022fcd7afabf9999eebc9b0 [file] [log] [blame]
Roman Elizarov8a4a8e12017-03-09 19:52:58 +03001/*
Roman Elizarovdb0ef0c2019-07-03 15:02:44 +03002 * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
Roman Elizarov8a4a8e12017-03-09 19:52:58 +03003 */
4
5// This file was automatically generated from coroutines-guide-reactive.md by Knit tool. Do not edit.
Roman Elizarov0950dfa2018-07-13 10:33:25 +03006package kotlinx.coroutines.rx2.guide.context02
Roman Elizarov8a4a8e12017-03-09 19:52:58 +03007
Roman Elizarov95981f32017-03-17 18:12:04 +03008import io.reactivex.*
Roman Elizarov0950dfa2018-07-13 10:33:25 +03009import kotlinx.coroutines.*
10import kotlinx.coroutines.reactive.*
11import kotlin.coroutines.CoroutineContext
Roman Elizarov8a4a8e12017-03-09 19:52:58 +030012
Vsevolod Tolstopyatovd100a3f2019-07-16 16:14:35 +030013fun rangeWithInterval(context: CoroutineContext, time: Long, start: Int, count: Int) = publish<Int>(context) {
Roman Elizarov8a4a8e12017-03-09 19:52:58 +030014 for (x in start until start + count) {
15 delay(time) // wait before sending each number
16 send(x)
17 }
18}
19
Prendota65e6c8c2018-10-17 11:51:08 +030020fun main() {
Roman Elizarovf189cec2018-09-11 19:16:49 +030021 Flowable.fromPublisher(rangeWithInterval(Dispatchers.Default, 100, 1, 3))
Roman Elizarov86349be2017-03-17 16:47:37 +030022 .subscribe { println("$it on thread ${Thread.currentThread().name}") }
Roman Elizarov8a4a8e12017-03-09 19:52:58 +030023 Thread.sleep(1000)
24}