28 lines
952 B
TypeScript
28 lines
952 B
TypeScript
import * as comlink from 'comlink';
|
|
import { Subscriber } from 'rxjs';
|
|
|
|
// Observers, ie. functions passed to `observable.subscribe(...)`, are converted to a subclass of `Subscriber` before they are sent to the source Observable.
|
|
// The conversion happens internally in the RxJS library - this transfer handler is catches them and wraps them with a proxy
|
|
const subscriberTransferHandler = {
|
|
canHandle(value: unknown): value is Subscriber<unknown> {
|
|
return Boolean(value && value instanceof Subscriber);
|
|
},
|
|
|
|
serialize(value: Function): [MessagePort, Transferable[]] {
|
|
const obj = comlink.proxy(value);
|
|
|
|
const { port1, port2 } = new MessageChannel();
|
|
|
|
comlink.expose(obj, port1);
|
|
|
|
return [port2, [port2]];
|
|
},
|
|
|
|
deserialize(value: MessagePort): comlink.Remote<MessagePort> {
|
|
value.start();
|
|
|
|
return comlink.wrap<MessagePort>(value);
|
|
},
|
|
};
|
|
comlink.transferHandlers.set('SubscriberHandler', subscriberTransferHandler);
|