Làm thế nào để trả về một thể quan sát được sản phẩm nào trong rxjs

Question

Chức năng more() có nghĩa vụ phải trả lại một Observable từ một yêu cầu 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(); 
      } 
     ); 
    } 
} 

Trong trường hợp này tôi chỉ có thể làm một yêu cầu nếu hasMore() là đúng, khác tôi nhận được một lỗi trên subscribe() chức năng subscribe is not defined, làm thế nào tôi có thể trả lại một sản phẩm nào có thể quan sát được?

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

Answer 1

Đối với nguyên cảo bạn có thể chỉ định param chung của quan sát được sản phẩm nào của bạn như thế này:

Observable.empty<Response>(); 

Answer 2

Vâng, có đang Empty hành

Rx.Observable.empty(); 

Đối với nguyên cảo, bạn có thể sử dụng from:

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

Answer 3

Bạn có thể trở Observable.of (empty_variable), ví dụ

Observable.of(''); 

// or 
Observable.of({}); 

// etc 

Answer 4

Hãy thử điều này

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

Hoặc bạn có thể thử ignoreElements() cũng

Answer 6

Trong trường hợp của tôi với Angular2 và rxjs , nó hoạt động với:

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

Answer 7

Với n cú pháp ew, ví dụ: rxjs 5.5+, điều này trở thành như sau:

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

empty(); 
of({}); 

Chỉ cần một điều cần lưu ý, empty() hoàn thành thể quan sát được, vì vậy nó sẽ không kích hoạt next trong luồng của mình, chỉ hoàn thành! Vì vậy, nếu bạn có tap, ví dụ, chúng có thể không kích hoạt như bạn muốn (xem ví dụ bên dưới).

trong khi of({}) tạo ra một quan sát và phát ra tiếp theo với giá trị {}, nó sẽ không hoàn thành một mình, có lẽ bạn nên làm of({}).pipe(take(1)) để phát ra và hoàn thành.

ví dụ:

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