/**
         * Consumer是簡易版的Observer，他有多重過載，可以自定義你需要處理的資訊，我這裡呼叫的是隻接受onNext訊息的方法，
         * 他只提供一個回撥介面accept，由於沒有onError和onCompete，無法再 接受到onError或者onCompete之後，實現函式回撥。
         * 無法回撥，並不代表不接收，他還是會接收到onCompete和onError之後做出預設操作，也就是監聽者（Consumer）不在接收
         * Observable傳送的訊息，下方的程式碼測試了該效果。
         */
        final Consumer<String> consumer = new Consumer<String>() {
            @Override
            public void accept(@NonNull String s) throws Exception {
                Log.d("MainActivity", Thread.currentThread().getName() + " String:" + s);
            }
        };

        Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
                Log.d("MainActivity", Thread.currentThread().getName() + "emit Hello");
                e.onNext("Hello");
                Log.d("MainActivity", Thread.currentThread().getName() + "emit Complete");
                e.onComplete();
                Log.d("MainActivity", Thread.currentThread().getName() + "emit World");
                e.onNext("World");
            }
        });