Observable.just("Hello, Aya!").subscribe (object : Observer<String>{
            override fun onComplete() {
                Log.i(TAG, "Complete")
            }

            override fun onSubscribe(d: Disposable) {
                Log.i(TAG, "onSubscribe")
            }

            override fun onNext(t: String) {
                Log.i(TAG, "Next: $t")
            }

            override fun onError(e: Throwable) {
                Log.i(TAG, "Error")
            }
        })