Function events

src/master/thread.ts:18–20

Return an observable that can be used to subscribe to internal events happening in the thread. Useful for debugging.

(thread: ThreadT)

  },
  /** Return an observable that can be used to subscribe to internal events happening in the thread. Useful for debugging. */
  events<ThreadT extends ThreadType>(thread: ThreadT): Observable<WorkerEvent> {
    return thread[$events] || fail("Events observable not found. Make sure to pass a thread instance as returned by the spawn() promise.")
  },
  /** Terminate a thread. Remember to terminate every thread when you are done using it. */
  terminate<ThreadT extends ThreadType>(thread: ThreadT) {
    return thread[$terminate]()