Guest User

Untitled

a guest
Aug 19th, 2018
94
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.82 KB | None | 0 0
  1. Observable<String> alphabets1 = Observable
  2. .interval(1, TimeUnit.SECONDS).map(id -> "A" + id);
  3.  
  4. Observable<String> alphabets2 = Observable
  5. .interval(1, TimeUnit.SECONDS).map(id -> "B" + id);
  6.  
  7. Observable.concat(alphabets1, alphabets2)
  8. .subscribe(new Observer<String>() {
  9. @Override
  10. public void onSubscribe(Disposable d) {
  11.  
  12. }
  13.  
  14. @Override
  15. public void onNext(String s) {
  16. System.out.println("onNext: " + s);
  17. }
  18.  
  19. @Override
  20. public void onError(Throwable e) {
  21.  
  22. }
  23.  
  24. @Override
  25. public void onComplete() {
  26.  
  27. }
  28. });
Add Comment
Please, Sign In to add comment