chore: refactor service

Author: IKatsuba

projects/demo/src/app/app.component.ts

@@ -11,7 +11,7 @@ export class AppComponent {
     public workerThread: WebWorker<string, string>;
 
     constructor(webWorkerExecutor: WebWorkerExecutor) {
-        this.workerThread = webWorkerExecutor.execute((result: string) =>
+        this.workerThread = webWorkerExecutor.createWorker((result: string) =>
             Promise.resolve(`Message from worker: ${result}`),
         );
     }

projects/workers/src/web-worker/services/web-worker-executor.service.ts

@@ -12,7 +12,19 @@ import {WebWorkerModule} from '../web-worker.module';
     },
 })
 export class WebWorkerExecutor {
-    execute<T, R>(fn: WebWorkerFunction<T, R>, options?: WorkerOptions): WebWorker<T, R> {
+    execute<T, R>(fn: WebWorkerFunction<T, R>, data: T): Promise<R> {
+        const worker = this.createWorker(fn);
+        const promise = worker.toPromise();
+
+        worker.next(data);
+
+        return promise;
+    }
+
+    createWorker<T, R>(
+        fn: WebWorkerFunction<T, R>,
+        options?: WorkerOptions,
+    ): WebWorker<T, R> {
         return WebWorker.fromFunction<T, R>(fn, options);
     }
 }