\n| \n\n```ts\n// ================= worker.ts ====================\n// traditional worker — simple enough\n// ================================================\n\nimport {parentPort, workerData} from 'node:worker_threads'\nimport {processImage} from './processImage'\n\nconst imageFiles = workerData\n\nparentPort.postMessage({\n type: 'started',\n expected: imageFiles.length,\n})\n\nlet processed = 0\nfor (let i = 0; i < imageFiles.length; i++) {\n const file = imageFiles[i]\n\n try {\n const result = await processImage(file)\n parentPort.postMessage({\n type: 'progress',\n file: file.name,\n completed: i + 1,\n result,\n })\n processed++\n } catch {\n // ...\n }\n}\n\nparentPort.postMessage({\n type: 'finished',\n processed,\n})\n```\n\n | \n\n\n\n```ts\n// ================ worker.ts ========================\n// worker-channel worker — still simple and type-safe!\n// ===================================================\nimport {parentPort, workerData} from 'node:worker_threads'\nimport {WorkerChannelReporter} from '@sanity/worker-channels'\nimport {processImage} from './processImage'\nimport type {ImageChannel} from '...'\n\nconst report = WorkerChannelReporter.from(parentPort)\nconst imageFiles = workerData\n\nreport.event.started({expected: imageFiles.length})\n\nlet processed = 0\nfor (let i = 0; i < imageFiles.length; i++) {\n const file = imageFiles[i]\n\n try {\n const result = await processImage(file)\n report.stream.progress.emit({\n file: file.name,\n completed: i + 1,\n result,\n })\n processed++\n } catch {\n // ...\n }\n}\nreport.stream.progress.end()\n\nreport.event.finished({processed})\n```\n\n | \n
\n\n\n| \n\n```ts\n// ================= main.ts ===================\n// a traditional parent — spaghetti control flow\n// =============================================\nimport {Worker} from 'node:worker_threads'\n\nconst worker = new Worker(/* ... */)\nlet expected = 0\n\nawait new Promise((resolve, reject) => {\n worker.on('message', (msg) => {\n switch (msg.type) {\n case 'started':\n expected = msg.expected\n console.log(`Processing ${expected} images...`)\n break\n case 'progress':\n const {file, completed} = msg\n console.log(`${file}: ${completed}/${expected}`)\n break\n case 'finished':\n const {processed} = msg\n console.log(`Processed ${processed}/${expected}`)\n resolve()\n break\n default:\n console.warn('Unknown message type:', msg.type)\n }\n })\n\n // don't forget to propagate errors\n worker.on('error', reject)\n})\n```\n\n | \n\n\n```ts\n// ==================== main.ts =======================\n// a worker-channel parent — control flow matches child\n// ====================================================\nimport {Worker} from 'node:worker_threads'\nimport {WorkerChannelReceiver} from '@sanity/worker-channels'\nimport type {ImageChannel} from '...'\n\nconst worker = new Worker(/* ... */)\n\nconst receiver = WorkerChannelReceiver.from(worker)\n\n// BONUS: the receiver automatically propagates errors\nconst {expected} = await receiver.event.started()\nconsole.log(`Processing ${expected} images...`)\n\nfor await (const progress of receiver.stream.progress()) {\n const {file, completed} = progress\n console.log(`${file}: ${completed}/${expected}`)\n}\n\nconst {processed} = await receiver.event.finished()\nconsole.log(`Processed ${processed}/${expected}`)\n\nreceiver.unsubscribe() // clean up after the worker\n```\n\n | \n
\n