L'abonnement rx kotlin ne fonctionne pas, ne reçoit pas les articles

Question

J'ai créé une fonction qui renvoie un Observable<String> avec des noms de fichiers, mais je n'obtiens aucun événement dans mon abonnement où j'appelle cette méthode. De plus il n'y a pas d'appel de onError ou onComplete
Voir mon code:

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")}) 
} 

Bien que tout est appelé dans la fonction getAllFiles(), donc ce que je manque?

Answer 1

observable est pour créer un Observable à partir de zéro, mais vous avez déjà Observable<String> de toObservable() de sorte que vous n'en avez pas besoin. Le code ci-dessous fonctionne pour moi:

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") }) 
} 

Vous pouvez également résoudre ce problème en changeant de:

.subscribe{subscriber} 

à

.subscribe(subscriber) 

mais la version imbriquée Observable est source de confusion pour moi.