typescript - EROARE TypeError: Ați furnizat 'undefined' acolo unde se aștepta un flux. Puteți furniza un Observable, Promise, Array sau Iterable în serviciile Angular

Am scris mai multe servicii pentru a accesa diferite API-uri. Serviciile scrise pentru post funcționează într-un fel, dar dau această eroare

EROARE TypeError: Ați oferit 'undefined' acolo unde se aștepta un flux. Puteți oferi un Observable, Promise, Array sau Iterable. la subscribeTo (subscribeTo.js:27)

În ceea ce privește serviciile scrise pentru metoda GET, apare aceeași eroare, dar nu primesc niciun date înapoi. Iată serviciul meu

GetClientData(): Observable<ClientDto> {
    let url_ = this.baseUrl + "https://xxxxxxxxxxxxxxxx/getClients";
    url_ = url_.replace(/[?&]$/, "");

    let options_ : any = {
        observe: "response",
        responseType: "blob",
        headers: new HttpHeaders({
            "Accept": "application/json"
        })
    };

    return this.http.request("get", url_, options_).pipe(_observableMergeMap((response_ : any) => {
        return this.processGetAllPermissions(response_);
    })).pipe(_observableCatch((response_: any) => {
        if (response_ instanceof HttpResponseBase) {
            try {
                return this.processGetAllPermissions(<any>response_);
            } catch (e) {
                return <Observable<ClientDto>><any>_observableThrow(e);
            }
        } else
            return <Observable<ClientDto>><any>_observableThrow(response_);
    }));
}

protected processGetAllPermissions(response: HttpResponseBase): Observable<ClientDto> {
    const status = response.status;
    const responseBlob = 
        response instanceof HttpResponse ? response.body : 
        (<any>response).error instanceof Blob ? (<any>response).error : undefined;

    let _headers: any = {}; if (response.headers) { for (let key of response.headers.keys()) { _headers[key] = response.headers.get(key); }};
    if (status === 200) {
        return blobToText(responseBlob).pipe(_observableMergeMap(_responseText => {
        let result200: any = null;
        let resultData200 = _responseText === "" ? null : JSON.parse(_responseText, this.jsonParseReviver);
        result200 = resultData200 ? ClientDto.fromJS(resultData200) : new ClientDto();
        return _observableOf(result200);
        }));
    } else if (status !== 200 && status !== 204) {
        return blobToText(responseBlob).pipe(_observableMergeMap(_responseText => {
        return throwException("An unexpected server error occurred.", status, _responseText, _headers);
        }));
    }
    return _observableOf<ClientDto>(<any>null);
}

Funcție Cloud

exports.getClients = functions.https.onRequest((req, res) => {

    res.set('Access-Control-Allow-Origin', 'http://localhost:4200');
    res.set('Access-Control-Allow-Methods', 'GET', 'POST');
    res.set('Access-Control-Allow-Headers', 'Content-Type');

    if (req.method === 'OPTIONS') {
        res.end();
    }

    else
    {

        let allClients = [];
        usersClients.get()
            .then(snapshot => {
                snapshot.forEach(doc => {
                    allClients.push(doc.data());
                });
                res.send(200, {
                    "data": allClients
                })
            })
            .catch(err => {
                console.log("Error getting data", err);
            });
    }
});

Răspuns #1

Ceva de genul acesta:

return this.http.get(url_, options_).pipe(
  map(data => {
    // Transform data here
  }),
  catchError(err => {
    // Handle errors here
  })
);

Răspunsul #2

Am avut aceeași eroare în proiectul meu Angular. A fost cauzată de un interceptor care gestiona erorile apelurilor API și nu returna nimic. Funcția mea catchError din apelul API returna această eroare. Soluția a fost să adaug acest lucru în handler-ul de erori al interceptorului

return throwError(...)