sample rxJava code

java

        Callable<List<String>> webService1Results1 = () -> {
            List<String> result = Arrays.asList("TWEET[3]","TWEET[2]","TWEET[1]");
            Thread.sleep(5000);
            return result;
        };
        Callable<List<String>> webService1Results2 = () -> {
            List<String> result = Arrays.asList("POST[3]","POST[2]","POST[1]");
            Thread.sleep(5000);
            return result;
        };

        Observable<List<String>> listObservable1 = Async.fromCallable(webService1Results1);
        Observable<List<String>> listObservable2 = Async.fromCallable(webService1Results2);

        Observable<String> stringObservable
                = listObservable1.mergeWith(listObservable2).flatMap(Observable::from);

        stringObservable.subscribe(System.out::println);

        Thread.sleep(5000);
        Thread.sleep(5000);