Worker message delivery

realms.worker-messaging

Ready · No signal has been run.

Results

Full evidence

Signal properties and values
Property	Value
No results yet. No signal has been run.

JSON

Selected signal results for external comparison. Field statuses, controls and exact values are retained.

No run export is available.

Source

Source is not connected yet.

// Test source pending.

Definition

Three sequential protocols preserve the 250 ms checkpoint and later receipt independently; parent scheduling remains context.

Find it in the repository

Collector source: core/signals/realms/worker-messaging.ts
Export: measurementModule · Signal object
Field definitions: core/definitions/realms/worker-messaging.ts
Capture membership: Product capture · common/capture/product.ts
Page registration: app/signals/registry.ts
Field projection: core/results/measurement.ts

Execution contract

Signal: realms.worker-messaging
Collector: realms.worker-messaging
API / surface: core/signals/realms/worker-messaging.ts
Timeout: 4000 ms
Companion signals: None
Fixture inputs: Declared requests (listed below)

Exact request inputs

[
  {
    "key": "realms.worker-messaging.responses",
    "inputs": {
      "ready": {
        "protocol": "ready",
        "source": "\npostMessage({ token, sequence: 0, kind: \"entry\" });\nonmessage = event => {\n  const data = event.data;\n  if (!data || data.token !== token || data.sequence !== 1) return;\n  if (data.protocol === \"ping\") postMessage({ token, sequence: 1, kind: \"reply\" });\n  if (data.protocol === \"port\" && event.ports[0]) {\n    const port = event.ports[0];\n    port.start(); port.postMessage({ token, sequence: 1, kind: \"reply\" }); port.close();\n  }\n};\nif (protocol === \"ready\") postMessage({ token, sequence: 1, kind: \"reply\" });\n",
        "type": "classic",
        "transport": "Blob",
        "checkpointsMs": [
          250,
          1000
        ],
        "clock": "parent performance.now",
        "maxLiveWorkers": 1
      },
      "ping": {
        "protocol": "ping",
        "source": "\npostMessage({ token, sequence: 0, kind: \"entry\" });\nonmessage = event => {\n  const data = event.data;\n  if (!data || data.token !== token || data.sequence !== 1) return;\n  if (data.protocol === \"ping\") postMessage({ token, sequence: 1, kind: \"reply\" });\n  if (data.protocol === \"port\" && event.ports[0]) {\n    const port = event.ports[0];\n    port.start(); port.postMessage({ token, sequence: 1, kind: \"reply\" }); port.close();\n  }\n};\nif (protocol === \"ready\") postMessage({ token, sequence: 1, kind: \"reply\" });\n",
        "type": "classic",
        "transport": "Blob",
        "checkpointsMs": [
          250,
          1000
        ],
        "clock": "parent performance.now",
        "maxLiveWorkers": 1
      },
      "port": {
        "protocol": "port",
        "source": "\npostMessage({ token, sequence: 0, kind: \"entry\" });\nonmessage = event => {\n  const data = event.data;\n  if (!data || data.token !== token || data.sequence !== 1) return;\n  if (data.protocol === \"ping\") postMessage({ token, sequence: 1, kind: \"reply\" });\n  if (data.protocol === \"port\" && event.ports[0]) {\n    const port = event.ports[0];\n    port.start(); port.postMessage({ token, sequence: 1, kind: \"reply\" }); port.close();\n  }\n};\nif (protocol === \"ready\") postMessage({ token, sequence: 1, kind: \"reply\" });\n",
        "type": "classic",
        "transport": "Blob",
        "checkpointsMs": [
          250,
          1000
        ],
        "clock": "parent performance.now",
        "maxLiveWorkers": 1
      }
    },
    "controls": {}
  }
]

One collector runs per invocation. Results and JSON select this signal’s fields; any companions execute in the same collector.

Generated source manifest lists runtime files, fixture URLs and content digests for this build. The Source tab provides a copyable console sample.

Run and edit locally

From the repository root, start the Astro app, then open /signals/realms.worker-messaging. Edit the collector source and reload the page to load its new build.

pnpm run dev:web

In a browser module served by this repository’s Vite graph:

import { createCollector } from "/core/collect"
import { measurementModule } from "/core/signals/realms/worker-messaging"

const signal = measurementModule
const collector = createCollector()
const suite = { signals: [signal] }
const result = await collector.collect(suite)

Reuse the collector owner for repeated calls so collection can enforce cleanup. This returns the collector’s raw result; app/signals/projection.ts selects the retained fields shown on this page.

rg -n 'measurementModule' core app tests
pnpm run check
pnpm run test tests/unit/app/focused-projection.test.ts