Как вернуть пустую наблюдаемый в rxjs

Question

Функции more() должен возвращать Observable из запроса 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(); 
      } 
     ); 
    } 
} 

В этом случае я могу только сделать запрос, если hasMore() верно, то я получаю сообщение об ошибке на subscribe() функция subscribe is not defined, как я могу вернуть пустой наблюдаемый?

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

Answer 1

Для машинописи можно указать общие параметры в вашем пустом наблюдаемом как это:

Observable.empty<Response>(); 

Answer 2

Да, есть я Empty оператор

Rx.Observable.empty(); 

Для машинописи, вы можете использовать from:

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

Answer 3

Вы можете вернуть Observable.of (empty_variable), например

Observable.of(''); 

// or 
Observable.of({}); 

// etc 

Answer 4

Попробуйте

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

Или вы можете попробовать ignoreElements(), а

Answer 6

В моем случае с Angular2 и rxjs , он работал с:

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

Answer 7

С n ew синтаксис, например. rxjs 5.5+, это становится следующим:

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

empty(); 
of({}); 

Только одна вещь, чтобы иметь в виду, empty() завершает наблюдаемым, поэтому он не будет вызывать next в вашем потоке, только завершается! Поэтому, если у вас есть tap, например, они могут не получить триггер по вашему желанию (см. Пример ниже).

а of({}) создает наблюдаемый и излучает рядом со значением {}, он не завершит наблюдаемый в одиночку, возможно, вы должны сделать of({}).pipe(take(1)) испускать и полные.

например.

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();