Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val isJosefAgeNeeded = true
- val isPeterAgeNeeded = true
- fun generateAsyncRandomIntNumber(max: Int): Observable<Int> {
- return Observable.create<Int> {
- Thread.sleep(Random().nextInt(750).toLong())
- it.onNext(Random().nextInt(max))
- it.onComplete()
- }
- }
- fun generateSyncRandomIntNumber(max: Int): Int {
- return Random().nextInt(max)
- }
- var josefAge = 0
- var peterAge = 0
- val call = Completable.create {
- if(isJosefAgeNeeded){
- josefAge = testRepository.generateSyncRandomIntNumber(75)
- }
- if(isPeterAgeNeeded){
- peterAge = testRepository.generateSyncRandomIntNumber(60)
- }
- it.onComplete()
- }.subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread())
- .subscribe({
- Log.d("Log", "Result: $josefAge & $peterAge")
- }, {
- Log.d("Log", "Error $it")
- })
Add Comment
Please, Sign In to add comment