Implementing Observer<T> and Observable<T>

rxexample1.kt

class ObservableObserverExample {

	fun main(args : Array<String>){
        	val myObserver = MyObserver()
        	val myObservable = MyObservable()
		myObservable.subscribe(myObserver)
    	}

    	class MyObserver : Observer<String>{
        	override fun onComplete() {
            		println("Sequences stream completed")
        	}
        	override fun onNext(value: String) {
            		println("Received value "+value)
        	}
        	override fun onError(e: Throwable) {
            		println("Error occurred while streaming sequences")
        	}
    	}

    	class MyObservable : Observable<String> {
		override fun subscribe(observer : Observer<String>) : Disposable {
			observer.onNext("a")
			observer.onNext("b")
			observer.onNext("c")
			observer.onCompleted()
			return Disposables.empty()
		}
	}
}