La suscripción de rx kotlin no funciona, no recibe artículos

Creé una function que devuelve un Observable<String> con nombres de file, pero no obtengo ningún evento en mi suscripción donde llamo a este método. Además, no hay ninguna llamada de onError o onComplete
Ver mi código:

 fun getAllFiles(): Observable<String> { val allFiles = File("/Users/stephan/Projects/Playground/kotlinfiles/") .listFiles { file -> !file.isDirectory() } return observable { subscriber -> allFiles.toObservable() .map { f -> "${f.name}" } .doOnNext { println("Found file $it") } .subscribe { subscriber} } } fun test() { getAllFiles() .doOnNext { println("File name$it") } .subscribe( {n -> println("File: $n")}, {e -> println("Damn: $e")}, {println("Completed")}) } 

Aunque se llama a todo en la function getAllFiles() , entonces ¿qué me estoy perdiendo?

• Comportamiento con Kotlin Higher-Order Functions e interfaces de método único?
• Llamada asincrónica para cada elemento dentro de una colección
• La biblioteca de Kotlin 'rxkotlin-0.21.0.jar' tiene un formatting no compatible. Actualice la biblioteca o el complemento
• RxKotlin flattenAsObservable (): no coincide con el método de reference
• Múltiples requestes de modificación2 usando Flowable en Kotlin

 fun getAllFiles(): Observable<String> { val allFiles = File("/Users/stephan/Projects/Playground/kotlinfiles/") .listFiles { file -> !file.isDirectory } return allFiles.toObservable() .map { f -> "${f.name}" } } fun test() { getAllFiles() .doOnNext { println("File name $it") } .subscribe( { n -> println("File: $n") }, { e -> println("Damn: $e") }, { println("Completed") }) } 

 .subscribe{subscriber} 

 .subscribe(subscriber)