I'm using Module Workers to run a number of complex tasks. These send back data while they are running via Observables. This works fine so far.
Now I'd like to have a pool of these Module Workers running. The issue is, using pool.queue() will not give me access to the worker that the task has been assigned to, thus I also can't subscribe to the Observables of that Worker. Is there a way to get the worker instance within the pool that my task is being assigned to?
I'm using Module Workers to run a number of complex tasks. These send back data while they are running via Observables. This works fine so far.
Now I'd like to have a pool of these Module Workers running. The issue is, using pool.queue() will not give me access to the worker that the task has been assigned to, thus I also can't subscribe to the Observables of that Worker. Is there a way to get the worker instance within the pool that my task is being assigned to?