Jak zwrócić pusty obserwowalne w rxjs

Question

funkcji more() ma zwrócić Observable od żądania GET

export class Collection{ 

    public more =(): Observable<Response> => { 
     if (this.hasMore()) { 

     return this.fetch(); 
     } 
     else{ 
     // return empty observable 
     } 
    } 

    private fetch =(): Observable<Response> => { 
     return this.http.get('some-url').map(
      (res) => { 
       return res.json(); 
      } 
     ); 
    } 
} 

W tym przypadku mogę zrobić tylko wniosek, jeśli hasMore() jest prawdą, inaczej pojawia się błąd na subscribe() funkcji subscribe is not defined, jak mogę zwrócić puste obserwowalne?

this.collection.more().subscribe(
    (res) =>{ 
     console.log(res); 
    }, 
    (err) =>{ 
     console.log(err); 
    } 
) 

Answer 1

Na maszynie można określić ogólny param twoich pusty obserwowalne tak:

Observable.empty<Response>(); 

Answer 2

Tak, to ja Empty operator

Rx.Observable.empty(); 

Na maszynie można użyć from:

Rx.Observable<Response>.from([]) 

Answer 3

Możesz powrócić Observable.of (empty_variable), na przykład

Observable.of(''); 

// or 
Observable.of({}); 

// etc 

Answer 4

Spróbuj

export class Collection{ 
public more(): Observable<Response> { 
    if (this.hasMore()) { 
    return this.fetch(); 
    } 
    else{ 
    return this.returnEmpty(); 
    }    
    } 
public returnEmpty(): any { 
    let subscription = source.subscribe(
     function (x) { 
     console.log('Next: %s', x); 
    }, 
    function (err) { 
     console.log('Error: %s', err); 
    }, 
    function() { 
     console.log('Completed'); 
    }); 
    } 
    } 
let source = Observable.empty(); 

Answer 5

Albo można spróbować ignoreElements() także

Answer 6

W moim przypadku z Angular2 i rxjs , działało z:

import {EmptyObservable} from 'rxjs/observable/EmptyObservable'; 
... 
return new EmptyObservable(); 
... 

Answer 7

Dzięki n nowa składnia np. rxjs 5.5+, staje się to w następujący sposób:

import { empty } from "rxjs/observable/empty"; 
import { of } from "rxjs/observable/of"; 

empty(); 
of({}); 

Tylko jedna rzecz, aby pamiętać, empty() zakończeniu obserwowalne, więc nie spowoduje next w strumieniu, tylko kończy! Więc jeśli masz na przykład tap, mogą nie zostać uruchomione, jak chcesz (patrz przykład poniżej).

natomiast of({}) tworzy zauważalny i emituje obok o wartości {}, to nie zakończy się zaobserwować sam, być może należy zrobić of({}).pipe(take(1)) emitować oraz kompletne.

np.

empty().pipe(
    tap(() => console.warn("i will not reach here, as i am complete")) 
).subscribe(); 

of({}).pipe(
    take(1), 
    tap(() => console.warn("i will reach here")) 
).subscribe();