50 lines
1.5 KiB
TypeScript
50 lines
1.5 KiB
TypeScript
import { IoSocketClient } from "../lib/communication/IoSocketClient";
|
|
import { IoSocketServer } from "../lib/communication/IoSocketServer";
|
|
import { getLinkedDispatcher } from "../lib/dispatcher/getLinkedDispatcher";
|
|
import { nopeDispatcher } from "../lib/dispatcher/nopeDispatcher";
|
|
import { exportFunctionToDispatcher } from "../lib/dispatcher/nopeDispatcherDecorators";
|
|
import { serviceRegistry } from "../lib/dispatcher/serviceRegistry";
|
|
import { generateBenchmarkFunction } from "../modules/funcs/generateBenchmarkFunction";
|
|
|
|
|
|
async function exportedFunc(a: number, b: number, operator: (a: number, b: number) => Promise<number>) {
|
|
return await operator(a, b)
|
|
}
|
|
|
|
export const test = exportFunctionToDispatcher(exportedFunc, {
|
|
uri: 'test'
|
|
})
|
|
export const benchmark = exportFunctionToDispatcher(generateBenchmarkFunction(1000, 'Executed'), {
|
|
uri: 'benchmark'
|
|
})
|
|
|
|
const serverIOSocket = new IoSocketServer(9002);
|
|
const dispatcher = getLinkedDispatcher({
|
|
communicator: serverIOSocket
|
|
});
|
|
|
|
const IOSocketClient = new IoSocketClient('ws://localhost:9002');
|
|
const local = new nopeDispatcher({
|
|
communicator: IOSocketClient
|
|
});
|
|
|
|
const serviceReg = new serviceRegistry({
|
|
communicator: IOSocketClient
|
|
})
|
|
|
|
async function main() {
|
|
let i = 0;
|
|
while (i <= 10000) {
|
|
await local.performCall('benchmark', []);
|
|
i++;
|
|
}
|
|
|
|
try {
|
|
await local.performCall('unkown', []);
|
|
} catch (e) {
|
|
console.log('Succes');
|
|
console.error(e)
|
|
}
|
|
}
|
|
|
|
main().catch(console.error) |