AsyncSubject.kt

//In this example no values will be published as the sequence never completes. No values will be written to the console.
fun asyncSubjectExample1(){
    var subject = new AsyncSubject<string>()
    subject.onNext("a")
    subject.onNext("b")
    subject.onNext("c")
    subject.subscribe(println(it))
}

//In this example we invoke the OnCompleted method so the last value 'c' is written to the console:
fun asyncSubjectExample2(){
    var subject = new AsyncSubject<string>()
    subject.onNext("a")
    subject.onNext("b")
    subject.onNext("c")
    subject.onCompleted()
    subject.subscribe(println(it))
}