Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class MainKotlinTest {
- @Test
- fun main() {
- println("Start")
- networkRequest()
- .subscribe { t ->
- println(t)
- saveDB(t).subscribe()
- }
- println("End")
- Thread.sleep(5000)
- }
- private fun <T> saveDB(data:T): Completable {
- return Completable.fromCallable {
- println("saveDB Start")
- Thread.sleep(2000)
- println("saveDB Success")
- println(data)
- }.subscribeOn(Schedulers.io())
- }
- private fun networkRequest(): Single<String> {
- return Single.fromCallable {
- println("networkRequest Start")
- Thread.sleep(2000)
- println("networkRequest Success")
- "RESULT REST"
- }.subscribeOn(Schedulers.io())
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment