AsyncSubject.java

        AsyncSubject<Integer> pSubject = AsyncSubject.create();
        pSubject.onNext(0);


        pSubject.subscribe(it -> System.out.println("Observer 1 onNext: " + it),
                (Throwable error) -> { }, () -> System.out.println("Observer 1 onComplete"),
                on1 -> System.out.println("Observer 1 onSubscribe"));

        pSubject.onNext(1);
        pSubject.onNext(2);


        pSubject.subscribe(it -> System.out.println("Observer 2 onNext: " + it),
                (Throwable error) -> { }, () -> System.out.println("Observer 2 onComplete"),
                on1 -> System.out.println("Observer 2 onSubscribe"));

        pSubject.onNext(3);
        pSubject.onNext(4);

        /* This is very important in AsyncSubject  */
        pSubject.onComplete();