comparison src/app/services/feature-extraction/FeatureExtractionWorker.ts @ 236:53ea6406d601

Generate new project with latest @angular/cli, including Angular 4.
author Lucas Thompson <dev@lucas.im>
date Tue, 25 Apr 2017 20:01:09 +0100
parents efa23f33393b
children 7106cdd59e62
comparison
equal deleted inserted replaced
235:76f2cd2c5a68 236:53ea6406d601
5 import {PiperVampService, ListRequest, ListResponse} from 'piper'; 5 import {PiperVampService, ListRequest, ListResponse} from 'piper';
6 import { 6 import {
7 SimpleRequest 7 SimpleRequest
8 } from 'piper/HigherLevelUtilities'; 8 } from 'piper/HigherLevelUtilities';
9 import { VampExamplePlugins } from 'piper/ext/VampExamplePluginsModule'; 9 import { VampExamplePlugins } from 'piper/ext/VampExamplePluginsModule';
10 import {AvailableLibraries} from "./feature-extraction.service"; 10 import {AvailableLibraries} from './feature-extraction.service';
11 import { 11 import {
12 DedicatedWorkerGlobalScope, 12 DedicatedWorkerGlobalScope,
13 WebWorkerStreamingServer 13 WebWorkerStreamingServer
14 } from "piper/servers/WebWorkerStreamingServer"; 14 } from 'piper/servers/WebWorkerStreamingServer';
15 import { 15 import {
16 PiperStreamingService, 16 PiperStreamingService,
17 StreamingResponse, 17 StreamingResponse,
18 StreamingService 18 StreamingService
19 } from "piper/StreamingService"; 19 } from 'piper/StreamingService';
20 import {Observable} from "rxjs/Observable"; 20 import {Observable} from 'rxjs/Observable';
21 import {EmscriptenModule} from "piper/PiperVampService"; 21 import {EmscriptenModule} from 'piper/PiperVampService';
22
23 22
24 interface MessageEvent { 23 interface MessageEvent {
25 readonly data: any; 24 readonly data: any;
26 } 25 }
27 26
62 } 61 }
63 62
64 collect(request: SimpleRequest): Observable<StreamingResponse> { 63 collect(request: SimpleRequest): Observable<StreamingResponse> {
65 const key = request.key.split(':')[0]; 64 const key = request.key.split(':')[0];
66 return this.services.has(key) ? 65 return this.services.has(key) ?
67 this.services.get(key).collect(request) : Observable.throw("Invalid key"); 66 this.services.get(key).collect(request) : Observable.throw('Invalid key');
68 } 67 }
69 } 68 }
70 69
71 export default class FeatureExtractionWorker { 70 export default class FeatureExtractionWorker {
72 private workerScope: DedicatedWorkerGlobalScope; 71 private workerScope: DedicatedWorkerGlobalScope;
113 console.error('Non registered library key.'); // TODO handle error 112 console.error('Non registered library key.'); // TODO handle error
114 } 113 }
115 break; 114 break;
116 case 'addRemoteLibraries': // TODO rename 115 case 'addRemoteLibraries': // TODO rename
117 const available: AvailableLibraries = ev.data.params; 116 const available: AvailableLibraries = ev.data.params;
118 Object.keys(available).forEach(key => { 117 Object.keys(available).forEach(libraryKey => {
119 this.remoteLibraries.set(key, available[key]); 118 this.remoteLibraries.set(libraryKey, available[libraryKey]);
120 }); 119 });
121 } 120 }
122 }; 121 };
123 } 122 }
124 } 123 }