product.service.ts

  getProducts(): Observable<(Products_allProducts_data)[]> {
    return this.apollo.watchQuery<Products>({query: this.query, pollInterval: 120000}).valueChanges.pipe(
      map(result => result.data.allProducts.data),
      filter((x): x is Products_allProducts_data[] => x !== null)
    );
  }