Toán tử RxJS waitUntil

In lại 作者：行者123 更新时间：2023-12-04 01:15:27 30 4

a: 1---2-3-4--5---6
b: ------T---------

o: ------1234-5---6

const { concat, interval, of, from } = rxjs;
const { share, delay, toArray, takeUntil, mergeMap } = rxjs.operators;

const waitUntil = signal$ => source$ => {
  const sharedSource$ = source$.pipe(share());
  return concat(
    sharedSource$.pipe(
      takeUntil(signal$),
      toArray(),
      mergeMap(from)
    ),
    sharedSource$
  );
}

const stopWaiting$ = of('signal').pipe(delay(2000));

const source$ = interval(500).pipe(
    waitUntil(stopWaiting$)
).subscribe(console.log);

30 4 0

• Toán tử RxJS waitUntil

  a: 1---2-3-4--5---6 b: ------T--------- o: ------1234-5---6 Sử dụng RxJS, có toán tử nào có thể hoàn thiện hình ảnh trên không? Tôi có luồng A, là luồng sự kiện ngẫu nhiên.

• Jenkins 管道 "waitUntil"- 更改尝试之间的延迟

  我们使用 Jenkins 管道进行构建和测试。构建完成后，我们在多个测量设备上运行自动化测试。 为了更好地了解所需的测试时间，我创建了一个测试阶段，它会定期检查测试的状态。当所有测试完成后，管道就完成

• Jenkins Pipeline waitUntil bash命令返回特定字符串

  我有一个管道阶段，我等待从 sh 脚本返回某个字符串，并且只有当字符串匹配时，才继续到下一个阶段，但是，它无法按预期工作: node('master') { stage("wait for b

• javascript - Webdriver.waitUntil 未按预期工作

  我正在使用 wedriverio 4.5: ./node_modules/.bin/wdio -v v4.5.2 我需要等到某个元素存在，如果不存在则处理这种情况。 例如: let element =

• python - Pyppeteer: {'waitUntil' : 'networkidle0' } 不等到页面加载完毕

  因此，如果我使用 await page.waitFor(9000) 或一些硬编码的等待号码，我的函数将等到页面加载。 但是，await page.goto(url, {'waitUntil': 'ne

• JavaScript 如何使用 event.waitUntil() 等待异步函数调用

  在学习 JavaScript 时，它建议使用 async/await，因为它比 .then 更具可读性，我同意。不幸的是，当谈到 PWA 服务 worker 时，async 似乎被遗忘了。 尝试为具有

• javascript - 无法在 'waitUntil' 上执行 'ExtendableEvent'

  我需要 chrome 注册 ID 将其作为参数发送给 API 调用，这样我就可以获取与注册 ID 对应的消息。我的代码如下: self.addEventListener('push', functio

• javascript - 在获取事件中同时使用 respondWith 和 waitUntil

  是否有必要在 respondWith(本身在 fetch 事件中)中使用 waitUntil？ respondWith 是否已经waitUntil 收到已解决的 promise ？ 对此的一些讨论是

• javascript - 同步事件中的 ServiceWorker 无法使用 waitUntil

  我已经正确安装了 ServiceWorker，我正在使用以下代码监听同步事件: self.addEventListener("sync", function(event) { console.lo

• java - 为什么 ElementsCollection 的 waitUntil 方法受到保护？

  正如您在文档中看到的，waitUntil 方法受到 ElementsCollection 的保护: http://selenide.org/javadoc/3.7/com/codeborne/sele

• javascript - webdriverio waitUntil 和 getUrl 与模式

  在 WebdriverIO 中，我想等到浏览器重定向到其中包含单词 project 的 URL。我尝试组合 waitUntil 和 getUrl 函数，但它给出了错误消息。 类型错误:browser.

• asynchronous - 是否有 Service Worker 启动 waitUntil 来延迟处理获取？

  是否可以让 Service Worker 等待开始处理 fetch 事件，直到 Service Worker 启动时异步工作完成？ 我有一个应用程序外壳，其路由在数据中定义。要在 service wo

• javascript - event.waitUntil 在 Service Worker 中做什么以及为什么需要它？

  MDN 建议您执行以下操作来创建和填充服务工作线程缓存: this.addEventListener('install', function(event) { event.waitUntil(

• c++ - 如何将 blockng waitUntil() 方法写入使用 std::atomics 的池

  我有一个验证类，它使用线程池来处理它的所有作业。 现在，当用户询问时，我会启动一个线程，通过从磁盘读取作业来为我的验证类提供作业。而且我确信在某一时刻阅读会比处理更快。因此，我想编写一个方法，允许该线

• node.js - waitUntil : 'domcontentloaded' 之后，并非所有 DOM 内容都准备就绪

  也许我正在翻译domcontentloaded错误，但我希望当时所有元素都可以访问，并且查询它们应该不会有问题。 考虑以下因素: await page.goto(url, { waitUntil: '

• javascript - 服务人员 : async await in combination with waituntil is not working properly

  在使用 async/await 语法时，我正在为 service worker 中的 promises 而苦苦挣扎。 以下情况:我收到推送通知，想处理点击事件。如果我将“旧”语法与 then 和 ca

• node.js - 有没有办法让 puppeteer 的 waitUntil "networkidle"只考虑 XHR (ajax) 请求？

  我正在使用 puppeteer 来评估我的测试应用程序中基于 javascript 的网页 HTML。 这是我用来确保所有数据都已加载的行: await page.setRequestIntercep

• javascript - 在 Cypress 测试中，如果预期的 XHR 请求未发出 : waitUntil() with click XHR condition? ，如何重试按钮单击？

  在非常高的级别上，我们单击一个命令建筑物控制点的按钮；打开或关闭灯。单击应该向服务器发送 POST 请求。问题是有时单击按钮但 POST 请求不会发出。该按钮没有指示它是否已被单击的功能(小幅增强)。