/**
 * Copyright (c) 2020, Microsoft Corporation (MIT License).
 */ import { parentPort , workerData } from 'worker_threads' ; import { Socket , createServer } from 'net' ; import { ConoutWorkerMessage , IWorkerData , getWorkerPipeName } from '../shared/conout' ; const conoutPipeName = ( workerData as IWorkerData ) . conoutPipeName ; const conoutSocket = new Socket ( ) ; conoutSocket . setEncoding ( 'utf8' ) ; conoutSocket . connect ( conoutPipeName , ( ) => { const server = createServer ( workerSocket => { conoutSocket . pipe ( workerSocket ) ; } ) ; server . listen ( getWorkerPipeName ( conoutPipeName ) ) ; parentPort . postMessage ( ConoutWorkerMessage . READY ) ; } ) ;