Are you searching for a RxJS concat operator that works like forkJoin? Then have a look at the following simple code that will do that for you.<\/p>\n\n\n\n
import { concat, EMPTY, Observable } from 'rxjs';\n\n\/**\n * Joins last values emitted by passed Observables.\n *\n * `concatJoin` is an operator that takes any number of Observables which\n * can be passed either as an array or directly as arguments. If no input\n * Observables are provided, resulting stream will complete immediately.\n *\n * `concatJoin` will wait for all passed Observables to complete one by\n * one and then it will emit an array with last values from corresponding\n * Observables. So if you pass `n` Observables to the operator, resulting\n * array will have `n` values, where first value is the last thing emitted\n * by the first Observable, second value is the last thing emitted by the\n * second Observable and so on. That means `concatJoin` will not emit more\n * than once and it will complete after that.\n *\n * @param {...Observable} sources Any number of Observables provided either\n * as an array or as an arguments passed directly to the operator.\n * @return {Observable} Observable emitting either an array of last values\n * emitted by passed Observables.\n *\/\nexport function concatJoin<T>(...sources: Array<Observable<T> | Observable<T>[]>): Observable<T[]> {\n \/\/ If the first and only other argument is an array assume it's been\n \/\/ called with `concatJoin([obs1, obs2, obs3])`\n if (sources.length === 1 && Array.isArray(sources[0])) {\n sources = sources[0] as Array<Observable<T>>;\n }\n\n if (sources.length === 0) {\n return EMPTY;\n }\n\n return new Observable((subscriber) => {\n const values: Array<T> = [];\n concat(...sources).subscribe(\n (value: T) => {\n values.push(value);\n },\n (err) => {\n subscriber.error(err);\n },\n () => {\n subscriber.next(values);\n subscriber.complete();\n }\n );\n });\n}<\/code><\/pre>\n\n\n\n<\/p>\n","protected":false},"excerpt":{"rendered":"
Are you searching for a RxJS concat operator that works like forkJoin? Then have a look at the following simple code that will do that for you.<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[32],"tags":[],"class_list":["post-2573","post","type-post","status-publish","format-standard","hentry","category-coding"],"aioseo_notices":[],"aioseo_head":"\n\t\t\n\t\n\t\n\t\n\t\n\t\t