webworkerService.ts

import { Injectable } from '@angular/core';
import {Subject} from 'rxjs/Rx';
import {PlatformLocation} from '@angular/common';
@Injectable()
export class WebWorkerService { 
  worker;
  workerResult: {[key: string]: Subject<any> } = {} ;
  workerUrl = window.location.origin +this.platformLocation.getBaseHrefFromDOM() + 'assets/scripts/worker.js';
  constructor(private platformLocation: PlatformLocation) {
    this.workerInit(this.workerUrl);
    this.onmessage();   
  } 
  
  newWidgetResult(widgetNumber) { 
    this.workerResult[widgetNumber] = new Subject<any>();  
  }  
  
  workerInit(fileUrl: string): void {  
    this.worker = new Worker(fileUrl);  
  }  
  
  postMessage(data: any): void { 
    this.worker.postMessage(data);  
  } 
  
  onmessage(): void {  
    const that = this;  
    this.worker.onmessage = function (data: any) { 
      that.workerResult[data.data.widget].next(data.data.data)     
      };   
  }
  
  terminate(): void {
     this.worker.terminate();   
  } 
}