Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public static void main(String[] args) throws InterruptedException {
- AtomicInteger a = new AtomicInteger();
- Observable<Object> objectObservable = Observable.create(subscriber -> {
- new Thread(() -> {
- while(true) {
- int i = a.incrementAndGet();
- try {
- Thread.sleep(4 * 1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- subscriber.onNext("result" + i);
- }
- }).start();
- });
- Subscription subscribe1 = objectObservable.subscribe(r -> {
- System.out.println(r);
- }, e -> {
- });
- Thread.sleep(1000);
- Subscription subscribe2 = objectObservable.subscribe(r -> {
- System.out.println(r);
- }, e -> {
- });
- }
Add Comment
Please, Sign In to add comment