lib/cdp: rewrite onMessage for internals
This commit is contained in:
parent
b537650f03
commit
02cce39e44
@ -129,13 +129,13 @@ export default async ({ pipe: { pipeWrite, pipeRead } = {}, port }) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
return {
|
return {
|
||||||
onMessage: (_callback, once = false) => {
|
onMessage: (callback) => {
|
||||||
const callback = once ? msg => {
|
|
||||||
_callback(msg);
|
|
||||||
messageCallbacks.splice(messageCallbacks.indexOf(callback), 1); // remove self
|
|
||||||
} : _callback;
|
|
||||||
|
|
||||||
messageCallbacks.push(callback);
|
messageCallbacks.push(callback);
|
||||||
|
|
||||||
|
// return function to unhook
|
||||||
|
return () => {
|
||||||
|
messageCallbacks.splice(messageCallbacks.indexOf(callback), 1);
|
||||||
|
};
|
||||||
},
|
},
|
||||||
|
|
||||||
sendMessage,
|
sendMessage,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user