RxJS reduce nicht fortgesetzt

Question

Warum der flatMap verursacht keine nachgelagerten Reduzierungen Feuer?

Ich habe Code wie:

handleFiles.flatMap(files => 
    Rx.Observable.from(files). 
    flatMap((file, i) => fileReader(file, i)). 
    reduce((form, file, i) => { 
    form.append('file[' + i + ']', result); 
    console.log('reduce step', file); 
    return form; 
    }, new FormData()). 
    tap(console.log.bind(console, 'after reduce')) 
). 
subscribe(console.log.bind(console, 'response')); 

Und das Problem ist, dass der Wasserhahn 'nach reduzieren' nie getroffen wird. Warum?

Das Protokoll ist wie:

reduce step [data] 
reduce step [data] 

Screenshot:

Answer 1

Wenn Dateien ein Array ist, dann verringern, sollte kündigen, wenn die beobachtbaren von Filereader zurückgegeben haben. Das Problem für diesen Code war, dass fileReader eine Observable zurückgegeben hat, die nicht abgeschlossen wurde.

Answer 2

Das Problem ist nicht in flatMap; es ist in der Art und Weise reduce funktioniert.

reduce liest in einem ganzen Strom und reduziert sie auf einen einzigen Wert, emittiert nur dann, wenn der Quellenstrom geschlossen ist. Wenn Ihr from(files) Strom nicht zu Ende, dann reduce wird nie ausgegeben seinen Wert.

Versuchen scan stattdessen verwendet; es emittiert jeden Zwischenschritt und scheint genau das zu sein, wonach Sie suchen.