如何返回rxjs

Question

功能more()空觀察到的是應該從一個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()是真的返回一個Observable，否則我得到一個錯誤在subscribe()函數subscribe is not defined，我怎樣才能返回一個空的可觀察？

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

Answer 1

爲打字稿，你可以指定你的空觀察到的通用PARAM這樣的：

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新語法例如rxjs 5.5+，這成爲如下：

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

empty(); 
of({}); 

只是有一點要記住，empty()完成可觀的，所以不會觸發流中next，只完成了！因此，如果你有tap例如他們可能不會觸發你想要的（見下面的例子）。

而of({})創建一個observable併發射下一個值爲{}，它將不會完成單獨的觀察，也許你應該做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();