Объединение наблюдаемых объектов массива

Question

Как объединить два или более наблюдаемых массива, т. Е. Observable<Object[]>, Observable<Object[]>, используя rxjs, чтобы вернуть один Observable<Object[]>?

forkJoin и merge излучают два массива Observable<Object[]> независимо.

getEmployeesLeavesByEmployeeNumber2(employeeNumber,afromDate,atoDate) {
    const scenario1 = this.afs.collection(`${environment.FB_LEAVES}`, ref => {
        let query: firebase.firestore.CollectionReference | firebase.firestore.Query = ref;
        query = query.where("employeeNumber", "==", employeeNumber);
        query = query.where("fromDate",">=",afromDate);
        query = query.where("fromDate","<=",atoDate);
        return query;

    }).snapshotChanges()
        .pipe(take(1))
        .pipe(
            map(changes => {
                return changes.map(a => {
                    const data = a.payload.doc.data() as Leave;
                    data.docId = a.payload.doc.id;
                    return data;
                })
            })
        ).pipe(map(leaves => {
            let leavesArr=leaves.filter(leave => leave.status!==environment.LEAVE_STATUS_DECLINED)
            return leavesArr;
        }));

    const scenario2 = this.afs.collection(`${environment.FB_LEAVES}`, ref => {
        let query: firebase.firestore.CollectionReference | firebase.firestore.Query = ref;
        query = query.where("employeeNumber", "==", employeeNumber);
        query = query.where("toDate","<=",afromDate);
        query = query.where("toDate","<=",atoDate);
        return query;

    }).snapshotChanges()
        .pipe(take(1))
        .pipe(
            map(changes => {
                return changes.map(a => {
                    const data = a.payload.doc.data() as Leave;
                    data.docId = a.payload.doc.id;
                    return data;
                })
            })
        ).pipe(map(leaves => {
            let leavesArr=leaves.filter(leave => leave.status!==environment.LEAVE_STATUS_DECLINED)
            return leavesArr;
        }));

    const scenario3 = this.afs.collection(`${environment.FB_LEAVES}`, ref => {
        let query: firebase.firestore.CollectionReference | firebase.firestore.Query = ref;
        query = query.where("employeeNumber", "==", employeeNumber);
        query = query.where("fromDate","<=",afromDate);
        return query;

    }).snapshotChanges()
        .pipe(take(1))
        .pipe(
            map(changes => {
                return changes.map(a => {
                    const data = a.payload.doc.data() as Leave;
                    data.docId = a.payload.doc.id;
                    return data;
                })
            })
        ).pipe(
            filter(leave => {
                return leave!==undefined;
            })
        );
    return merge(scenario1,scenario2);
}

Я ожидаю одну наблюдаемую часть массива, но получаю 2, т.е.

emp's leaves:  [{…}]
assign.component.ts:198 leaves array length at assignment error  1
assign.component.ts:168 emp's leaves:  (2) [{…}, {…}]
assign.component.ts:198 leaves array length at assignment error  2

Answer 1

Я получил его на работу, используя:

return forkJoin(scenario1,scenario2).pipe(map((arr) => [...arr[0],...arr[1]] ));