Programim dhe zhvillim, javascript, python, php, html

A mund të përziej premtimet asinkronike/pritëse me RXJS të vëzhgueshme?

Unë jam duke punuar me vëzhgues jonikë/këndorë dhe RXJS.

Po përpiqem të rifaktoj kodin tim duke përdorur vëzhgues Rxjs dhe kam kodin vijues:

ionViewWillEnter() {
    if (this.platform.is('core') || this.platform.is('mobileweb')) {
      this.lat = 37.3675506;
      this.lng = -6.0452695;
      this.printMap();
    } else {
      if (this.platform.is('android')) {       
        this.tryGeolocation();            
      } else if (this.platform.is('ios')) {
        console.log("IOS")
      }
    }
  }

Nëse aksesi i përdoruesit nga celulari android, duhet të kontrolloj: isLocationAuthorized, isLocationEnabled() për të marrë pozicionin aktual me getCurrentPosition(), atëherë duhet të printoj Hartën ku përdor Observables forkjoin.

Problemi është të kontrollosh metodat e kthimit të premtimeve dhe nuk di si ta lidh këtë rrjedhë.

tryGeolocation është më poshtë:

 async tryGeolocation() {
    try {
      if (await this.diagnostic.isLocationAuthorized()) {
        if (await this.diagnostic.isLocationEnabled()) {
          this.loading = this.loadingCtrl.create({
            content: 'Localizando...',
            dismissOnPageChange: true
          });
          this.loading.present();
          const {coords} = await this.geolocation.getCurrentPosition();
          this.lat = coords.latitude;
          this.lng = coords.longitude;
          this.loading.dismiss();
          alert(this.lat);
          alert(this.lng);
          this.printMap();
        } else {
         console.log("error1")
        }
      } else {
console.log("error2")
      }
    } catch (e) {
      console.log('Error getting location', e);
    }
  }


printMap() {
    let obs1 = this._sp.getLocationsByPosition(this.lat, this.lng);
    let obs2 = this._sp.getUserFavoriteLocations2();
    this.subscription = forkJoin([obs1, obs2]).subscribe(results => {
      this.allLocations = results[0];
      this.myLocations = results[1];
      this.allLocations = this.allLocations.filter(item => !this.myLocations.some(other => item.id.sid_location === other.id.sid_location && item.id.bid_environment === other.id.bid_environment));   

      this.map = new google.maps.Map(this.mapElement.nativeElement, {
        zoom: 13,
        center: {lat: parseFloat(this.lat), lng: parseFloat(this.lng)},
        zoomControl: true,
        draggable: true            
      });

      new google.maps.Marker({
        position: {lat: parseFloat(this.lat), lng: parseFloat(this.lng)},
        map: this.map,
        icon: {
          url: "https://maps.gstatic.com/mapfiles/api-3/images/spotlight-poi2_hdpi.png"
        }
      });
      this.printMarkers();
    });
  }

Unë jam përpjekur të konvertoj premtimin në të vëzhgueshme si kjo:

let obs1 = Observable.fromPromise(this.diagnostic.isLocationAuthorized());
    let obs2 = Observable.fromPromise(this.diagnostic.isLocationEnabled());
    let obs3 = Observable.fromPromise(this.geolocation.getCurrentPosition());

    obs1.flatMap(() => obs2)
      .flatMap(() => obs3)
      .subscribe(coords => {
        console.log(coords);
//CALL TO printMap?
      })

A mund të më ndihmojë dikush që të arrij këtë rrjedhë duke rifaktoruar kodin tim?

Ju falenderoj paraprakisht

ionic-framework angular observable rxjs rxjs5
15.01.2019

Përgjigjet:


1

Rxjs observables and Promises. Shtyre dokumentet.

Duke thënë se, fromPromise është i vjetëruar, ai nuk shfaqet më në dokumentacioni. Përdor from për të marrë një të vëzhgueshme nga një premtim.

import { from } from 'rxjs';

let obs1 = from(this.diagnostic.isLocationAuthorized());
let obs2 = fromPromise(this.diagnostic.isLocationEnabled());
let obs3 = fromPromise(this.geolocation.getCurrentPosition());

Por mendoni nëse ia vlen për rastin tuaj të përdorimit. Kjo përgjigje do t'ju ndihmojë të vendosni.

Rezulton se mund të përzieni asinkronizimin e pritjes me të vëzhgueshme, por kjo nuk do të thotë se do t'i përshtatet rastit tuaj të përdorimit. (përdoreni këtë kod me kujdes)

import { defer } from 'rxjs';
defer(async function() {
  const a = await promiseDelay(1000).then(() => 1);
  const b = a + await promiseDelay(1000).then(() => 2);
  return a + b + await promiseDelay(1000).then(() => 3);
})
.subscribe(x => console.log(x)) // logs 7
16.01.2019
  • Ju keni shkruar «Async-wait dhe Observables nuk funksionojnë së bashku. » dhe faqja që keni lidhur thotë «RxJS, që nga fillimi, ka pasur një shkallë të lartë ndërveprueshmërie me Promises. », duke vazhduar të shpjegojë në detaje se si ata bëjnë punojnë mirë së bashku... 07.08.2019

    • 2

    Ju mund të përdorni from dhe combineLatest për të rxjs-fiksuar zinxhirët tuaj të premtimit. Unë postova një shembull stackblitz këtu - https://stackblitz.com/edit/rxjs-jnrj37?devtoolsheight=60

    në thelb diçka si kjo:

    import { combineLatest, from, of } from "rxjs";
import { map } from "rxjs/operators";

const promiseMaker = timeInMS =>
  new Promise((resolve, reject) => {
    setTimeout(() => {
      console.log("promise done");
      resolve("foo");
    }, timeInMS);
  });

const promise1$ = from(promiseMaker(300));

const promise2$ = from(promiseMaker(500));

const promise3$ = from(promiseMaker(800));

combineLatest(promise1$, promise2$, promise3$).subscribe(() =>
  console.log("Ready!!!")
);

    nëse premtimet varen nga njëra-tjetra, atëherë në vend të combineLatest mund të përdorni switchMap ose mergeMap dhe t'i lidhni ato me zinxhir sipas nevojës

    08.03.2021
    Materiale të reja
    Masterclass Coroutines: Kapitulli-3: Anulimi i korutinave dhe trajtimi i përjashtimeve.
    Mirë se vini në udhëzuesin gjithëpërfshirës mbi Kotlin Coroutines! Në këtë seri artikujsh, unë do t'ju çoj në një udhëtim magjepsës, duke filluar nga bazat dhe gradualisht duke u thelluar në..
    Faketojeni derisa ta arrini me të dhënat false
    A e gjeni ndonjëherë veten duke ndërtuar një aplikacion të ri dhe keni nevojë për të dhëna testimi që duken dhe duken më realiste ose një grup i madh të dhënash për performancën e ngarkesës...
    Si të përdorni kërkesën API në Python
    Kërkesë API në GitHub për të marrë depot e përdoruesve duke përdorur Python. Në këtë artikull, unë shpjegoj procesin hap pas hapi për të trajtuar një kërkesë API për të marrë të dhëna nga..
    Një udhëzues hap pas hapi për të zotëruar React
    Në këtë artikull, do të mësoni se si të krijoni aplikacionin React, do të mësoni se si funksionon React dhe konceptet thelbësore që duhet të dini për të ndërtuar aplikacione React. Learning..
    AI dhe Psikologjia — Pjesa 2
    Në pjesën 2 të serisë sonë të AI dhe Psikologji ne diskutojmë se si makineritë mbledhin dhe përpunojnë të dhëna për të mësuar emocione dhe ndjenja të ndryshme në mendjen e njeriut, duke ndihmuar..
    Esencialet e punës ditore të kodit tim VS
    Shtesat e mia të preferuara - Git Graph 💹 Kjo shtesë është vërtet e mahnitshme, e përdor përpara se të filloj të punoj për të kontrolluar dy herë ndryshimet dhe degët më të fundit, mund të..
    Pse Python? Zbulimi i fuqisë së gjithanshme të një gjiganti programues
    Në peizazhin gjithnjë në zhvillim të gjuhëve të programimit, Python është shfaqur si një forcë dominuese. Rritja e tij meteorike nuk është rastësi. Joshja e Python qëndron në thjeshtësinë,..