Mercurial > hg > ugly-duckling
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 } |