Come attendere per più richieste

0

Domanda

Sto cercando di capire qual è il modo migliore per attendere più richieste e di fare qualcosa quando sono fatto, tenere a mente che sia richiesta pranzo, al tempo stesso, e non si aspettano a vicenda.

  // table filling
  public SUB_getActSearch: Subscription;


  // table filling 2
  public SUB_getDeclarationSearch: Subscription;

  public fillTable(): void {
    const searchOBJ = {
      CreateDateFrom: this.currentDate,
      CreateDateTo: this.currentDate,
      ActNumber: this.ActNumber == undefined ? '' : this.ActNumber,
      vinCode: this.vinCode == undefined ? '' : this.vinCode,
      GovNumber: this.GovNumber == undefined ? '' : this.GovNumber,
      IsFromDashboard: true
    };
    const searchOBJ2 = {
      ActNumber: this.ActNumber == undefined ? '' : this.ActNumber,
      vinCode: this.vinCode == undefined ? '' : this.vinCode,
      GovNumber: this.GovNumber == undefined ? '' : this.GovNumber,
    };
    if ((this.ActNumber && this.ActNumber != undefined && this.ActNumber != null) || (this.vinCode && this.vinCode != undefined && this.vinCode != null) || (this.GovNumber && this.GovNumber != undefined && this.GovNumber != null)) {
      this.SUB_getActSearch = this.searchService.getActSearch({ ...searchOBJ2, PageSize: this.pageSize, PageNumber: this.currentPage }).subscribe((res) => {
        this.Act_Data = [];
        let headerPagin = JSON.parse(res.headers.get('X-Pagination'));
        this.elementsLength = headerPagin.totalCount;
        this.currentPage = headerPagin.currentPage;
        this.pageSize = headerPagin.pageSize;
        res.body.map((param) => {
          this.Act_Data.push(param);
        });
        this.ActDataSource = new MatTableDataSource<Element>(this.Act_Data);
        // console.log('Your form data : ', this.ActDataSource);
      });
    } else {
      this.SUB_getActSearch = this.searchService.getActSearch({ ...searchOBJ, PageSize: this.pageSize, PageNumber: this.currentPage }).subscribe((res) => {
        this.Act_Data = [];
        let headerPagin = JSON.parse(res.headers.get('X-Pagination'));
        this.elementsLength = headerPagin.totalCount;
        this.currentPage = headerPagin.currentPage;
        this.pageSize = headerPagin.pageSize;
        res.body.map((param) => {
          this.Act_Data.push(param);
        });
        this.ActDataSource = new MatTableDataSource<Element>(this.Act_Data);
        // console.log('Your form data : ', this.ActDataSource);
      });
    }
  }


  public fillTable2(): void {
    const searchOBJ = {
      DeclarationCreateDateFrom: this.currentDate.substring(0, 10),
      DeclarationCreateDateTo: this.currentDate,
      DeclarationNumber: this.ActNumber == undefined ? '' : this.ActNumber,
      VinCode: this.vinCode == undefined ? '' : this.vinCode,
      TransitNumber: this.GovNumber == undefined ? '' : this.GovNumber,
    };
    const searchOBJ2 = {
      DeclarationNumber: this.ActNumber == undefined ? '' : this.ActNumber,
      VinCode: this.vinCode == undefined ? '' : this.vinCode,
      TransitNumber: this.GovNumber == undefined ? '' : this.GovNumber,
    };
    if ((this.ActNumber && this.ActNumber != undefined && this.ActNumber != null) || (this.vinCode && this.vinCode != undefined && this.vinCode != null) || (this.GovNumber && this.GovNumber != undefined && this.GovNumber != null)) {
      this.SUB_getDeclarationSearch = this.declarationsService.getDeclarations({ ...searchOBJ, IsFromDashboard: true, PageSize: this.pageSizeDecl, PageNumber: this.currentPageDecl }).subscribe((res) => {
        this.Declaration_Data = [];
        let headerPaginDecl = JSON.parse(res.headers.get('X-Pagination'));
        this.elementsLengthDecl = headerPaginDecl.totalCount;
        this.currentPageDecl = headerPaginDecl.currentPage;
        this.pageSizeDecl = headerPaginDecl.pageSize;
        res.body.map((param) => {
          this.Declaration_Data.push(param);
        });
        this.DeclarationDataSource = new MatTableDataSource<Element>(this.Declaration_Data);
        // console.log('Your form data : ', this.DeclarationDataSource);
      });
    } else {
      this.SUB_getDeclarationSearch = this.declarationsService.getDeclarations({ ...searchOBJ, IsFromDashboard: true, PageSize: this.pageSizeDecl, PageNumber: this.currentPageDecl }).subscribe((res) => {
        this.Declaration_Data = [];
        let headerPaginDecl = JSON.parse(res.headers.get('X-Pagination'));
        this.elementsLengthDecl = headerPaginDecl.totalCount;
        this.currentPageDecl = headerPaginDecl.currentPage;
        this.pageSizeDecl = headerPaginDecl.pageSize;
        res.body.map((param) => {
          this.Declaration_Data.push(param);
        });
        this.DeclarationDataSource = new MatTableDataSource<Element>(this.Declaration_Data);
        // console.log('Your form data : ', this.DeclarationDataSource);
      });
    }
  }

Ci sono due metodi che sono chiamati all'interno ngoninit: fillTable() e fillTable2().

Ho provato ad utilizzare il metodo riportato di seguito per ascoltare le sottoscrizioni e attendere per loro

  public testingforkJoin(): void {
    forkJoin([this.SUB_getActSearch, this.SUB_getDeclarationSearch]
    ).subscribe(val => 
console.log("xxxxx", val));
// call some method here as soon as both are done
  }

Ma a quanto pare forkJoin non può ascoltare le sottoscrizioni, non c'è altro modo simile a forkjoin per gli abbonamenti?

Ci sono due metodi che includono la le richieste HTTP e voglio aspettare di rete richieste per completare e fare qualcosa al più presto a loro sono finiti.

angular asynchronous fork-join subscribe
2021-11-24 06:11:59
2

Migliore risposta

1

Io di solito dichiarare alcune variabili booleane per risolvere questo tipo di asincrono problema. Nel tuo caso è guardato come:

isSearch: boolean; isDeclarationSearch: boolean;

E poi ho inizializzato ogni variabile false, e alla fine di ogni variabile, modificare il valore vero, e poi ho creato la nuova funzione che funziona quando entrambi i valori sono vere.

2021-11-24 06:38:30

Credo che l'unico modo per farlo nel mio caso
nevaehteekay
1

Il punto di forkJoin è che si potrebbe sottoscrivere, non separatamente, essa restituisce il risultato in un colpo di iscrizione

let call: [] = [];

call.push(this.declarationsService.getDeclarations1()); call.push(this.declarationsService.getDeclarations2()); call.push(this.declarationsService.getDeclarations3());

forkJoin(call).subscribe((res) => {  }); 

o

 forkJoin({
 'prop1' :this.declarationsService.getDeclarations1()
 'prop2' : this.declarationsService.getDeclarations2()
}).subscribe((result) => { result.prop1; result.prop2   }); 
2021-11-24 06:41:33

In altre lingue

Questa pagina è in altre lingue

Русский
..................................................................................................................
Polski
..................................................................................................................
Română
..................................................................................................................
한국어
..................................................................................................................
हिन्दी
..................................................................................................................
Français
..................................................................................................................
Türk
..................................................................................................................
Česk
..................................................................................................................
Português
..................................................................................................................
ไทย
..................................................................................................................
中文
..................................................................................................................
Español
..................................................................................................................
Slovenský
..................................................................................................................