%PDF- <> %âãÏÓ endobj 2 0 obj <> endobj 3 0 obj <>/ExtGState<>/ProcSet[/PDF/Text/ImageB/ImageC/ImageI] >>/Annots[ 28 0 R 29 0 R] /MediaBox[ 0 0 595.5 842.25] /Contents 4 0 R/Group<>/Tabs/S>> endobj ºaâÚÎΞ-ÌE1ÍØÄ÷{òò2ÿ ÛÖ^ÔÀá TÎ{¦?§®¥kuµùÕ5sLOšuY>endobj 2 0 obj<>endobj 2 0 obj<>endobj 2 0 obj<>endobj 2 0 obj<> endobj 2 0 obj<>endobj 2 0 obj<>es 3 0 R>> endobj 2 0 obj<> ox[ 0.000000 0.000000 609.600000 935.600000]/Fi endobj 3 0 obj<> endobj 7 1 obj<>/ProcSet[/PDF/Text/ImageB/ImageC/ImageI]>>/Subtype/Form>> stream
'use strict'; const common = require('../common'); const assert = require('assert'); const cluster = require('cluster'); const net = require('net'); if (cluster.isPrimary) { const buf = Buffer.from('foobar'); cluster.setupPrimary({ stdio: ['pipe', 'pipe', 'pipe', 'ipc', 'pipe'] }); const worker = cluster.fork(); const channel = worker.process.stdio[4]; let response = ''; worker.on('exit', common.mustCall((code, signal) => { assert.strictEqual(code, 0); assert.strictEqual(signal, null); })); channel.setEncoding('utf8'); channel.on('data', (data) => { response += data; if (response === buf.toString()) { worker.disconnect(); } }); channel.write(buf); } else { const pipe = new net.Socket({ fd: 4 }); pipe.unref(); pipe.on('data', (data) => { assert.ok(data instanceof Buffer); pipe.write(data); }); }