How to use the lastValueFrom function from rxjs

completion-listener.js

GitHub: haley10309/graduation_project_frontend

63
64
65
66
67
68
69
70
71
72
 *
 * @returns A Promise that resolves if the success condition is met, or rejects otherwise.
 */
listen(commands) {
    const closeStreams = commands.map((command) => command.close);
    return Rx.lastValueFrom(Rx.merge(...closeStreams).pipe((0, operators_1.bufferCount)(closeStreams.length), (0, operators_1.switchMap)((exitInfos) => this.isSuccess(exitInfos)
        ? this.emitWithScheduler(Rx.of(exitInfos))
        : this.emitWithScheduler(Rx.throwError(exitInfos))), (0, operators_1.take)(1)));
}
emitWithScheduler(input) {

0

0

1

+ 13 other calls in file

external-context-creator.js

GitHub: kazuohagy/node-modules-backend

146
147
148
149
150
151
152
153
154
155
        ? value
        : this.pipesConsumer.apply(value, { metatype, type, data }, pipes);
}
async transformToResult(resultOrDeferred) {
    if (rxjs_1.isObservable(resultOrDeferred)) {
        return rxjs_1.lastValueFrom(resultOrDeferred);
    }
    return resultOrDeferred;
}
createGuardsFn(guards, instance, callback, contextType) {

0

0

0

scrapeLinkedIn.js

GitHub: Aditya-13/linkedin-connector

95
96
97
98
99
100
101
102
103
const activeEmployeesObservable = await fetchEachProfileActivityInParallel(
  page,
  profileLinks,
  waitUntilOptions
);
const activeEmployees = await rxjs.lastValueFrom(activeEmployeesObservable);

//Save profiles to a file
// saveProfiles(activeEmployees);

0

0

0

update-sets.js

GitHub: gabriel-gn/vercel-nextjs-serverless

94
95
96
97
98
99
100
101
102
103
if (!fs.existsSync(dir)) {
  fs.mkdirSync(dir, { recursive: true });
}
fs.writeFileSync(`${filepath}`, JSON.stringify([])); // CRIA O ARQUIVO VAZIO!
const downloadPath = `${downloadUrl}/core/${lang}/data/globals-${lang}.json`;
let globalsFile = await rxjs.lastValueFrom(
  new http.HttpService().get(downloadPath).pipe(
    // rxjs.tap((response) => {console.log(`Request GET: ${downloadPath}`)}),
    rxjs.map((response) => response.data),
  ),

0

0

0