| /third_party/node/test/parallel/ |
| H A D | test-whatwg-webstreams-transfer.js | 60 // 3. ReadableStream R2 is passed to the port1.onmessage callback as the
62 // 4. Within port1.onmessage, we transfer ReadableStream R2 to port1, which
66 // 5. ReadableStream R3 is passed to the port2.onmessage callback as the
68 // 6. Once the reader is attached to R3 in the port2.onmessage callback,
89 port2.onmessage = common.mustCall(({ data }) => {
100 port1.onmessage = common.mustCall(({ data }) => {
137 port2.onmessage = common.mustCall(({ data }) => {
149 port1.onmessage = common.mustCall(({ data }) => {
176 // The port1.onmessage callback receives WritableStream W2 and
180 // port2.onmessage
[all...] |
| H A D | test-abortsignal-cloneable.js | 26 mc.port1.onmessage = common.mustCall(({ data }) => {
66 mc.port1.onmessage = common.mustCall(({ data }) => {
80 mc.port1.onmessage = common.mustCall();
|
| H A D | test-worker-message-port-transfer-closed.js | 13 port1.onmessage = common.mustNotCall();
14 port2.onmessage = common.mustNotCall();
|
| H A D | test-worker-message-port.js | 34 port1.onmessage = common.mustCall((message) => {
43 port2.onmessage = common.mustCall((message) => {
182 'close', 'constructor', 'hasRef', 'onmessage', 'onmessageerror',
|
| H A D | test-worker-message-port-close.js | 46 ch.port1.onmessage = common.mustNotCall();
|
| /third_party/node/test/fixtures/ |
| H A D | child-process-spawn-node.js | 4 function onmessage(m) { function
7 process.removeListener('message', onmessage);
10 process.on('message', onmessage);
|
| /third_party/node/test/fixtures/wpt/webmessaging/broadcastchannel/resources/ |
| H A D | worker.js | 18 c.onmessage = e => {
32 onmessage = e => handler(e, postMessage);
36 port.onmessage = e => handler(e, msg => port.postMessage(msg));
|
| /third_party/node/lib/internal/per_context/ |
| H A D | messageport.js | 32 if (typeof this.onmessage === 'function')
33 this.onmessage(event);
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-broker/mount-origin/ |
| H A D | example.js | 41 subscriber_ws.onmessage =function got_packet(msg) {
61 publisher_ws.onmessage =function got_packet(msg) {
|
| /third_party/node/test/fixtures/wpt/resources/ |
| H A D | channel.sub.js | 54 async getOrCreate(type, uuid, onmessage=null) {
60 if (onmessage !== null) {
61 socket.onmessage = onmessage;
77 if (onmessage !== null) {
159 * @param {Function} onmessage - Event handler function for
162 async connect(onmessage) {
166 this.socket = await socketCache.getOrCreate(this.type, this.uuid, onmessage);
|
| /third_party/node/test/fixtures/wpt/streams/transferable/resources/ |
| H A D | service-worker.js | 4 onmessage = msg => {
|
| /third_party/node/benchmark/worker/ |
| H A D | messageport.js | 40 port2.onmessage = listener;
|
| /third_party/node/lib/internal/cluster/ |
| H A D | child.js | 53 process.on('internalMessage', internal(worker, onmessage));
56 function onmessage(message, handle) {
|
| /third_party/node/lib/internal/webstreams/ |
| H A D | transfer.js | 113 port.onmessage = ({ data }) => {
182 port.onmessage = ({ data }) => {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-pmd-bulk/mount-origin/ |
| H A D | example.js | 42 ws.onmessage = function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads-foreign-libuv-smp/mount-origin/ |
| H A D | example.js | 42 ws.onmessage =function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/client-server/minimal-ws-proxy/mount-origin/ |
| H A D | example.js | 42 ws.onmessage =function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-raw-proxy/mount-origin/ |
| H A D | example.js | 42 ws.onmessage =function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threadpool/mount-origin/ |
| H A D | example.js | 48 ws.onmessage = function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-timer/mount-origin/ |
| H A D | example.js | 42 ws.onmessage =function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server/mount-origin/ |
| H A D | example.js | 42 ws.onmessage =function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-ring/mount-origin/ |
| H A D | example.js | 41 ws.onmessage =function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-pmd/mount-origin/ |
| H A D | example.js | 43 ws.onmessage =function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads/mount-origin/ |
| H A D | example.js | 42 ws.onmessage =function got_packet(msg) {
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-pmd-corner/mount-origin/ |
| H A D | example.js | 47 ws[n].onmessage = function got_packet(msg) {
|