import {
+ availableParallelism,
ClusterWorker,
- DynamicThreadPool,
- availableParallelism
+ DynamicThreadPool
} from 'poolifier'
import { type RawData, WebSocketServer } from 'ws'
+
import {
type ClusterWorkerData,
type ClusterWorkerResponse,
workerData?: ClusterWorkerData
): ClusterWorkerResponse => {
const { port, workerFile, minWorkers, maxWorkers, ...poolOptions } =
- workerData as ClusterWorkerData
+ workerData!
WebSocketServerWorker.requestHandlerPool = new DynamicThreadPool<
ThreadWorkerData<DataPayload>,
data: response.data
})
)
- return null
+ return undefined
})
.catch(emptyFunction)
break
data: response.data
})
)
- return null
+ return undefined
})
.catch(emptyFunction)
break