Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 | 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x | // Copyright (c) ZeroC, Inc.
import { Ice } from "@zeroc/ice";
import { Test } from "./Test.js";
import { TestHelper } from "../../Common/TestHelper.js";
import { MyDerivedClassI } from "./MyDerivedClassI.js";
export class Server extends TestHelper {
async run(args) {
let communicator = null;
let echo = null;
try {
const [properties] = this.createTestProperties(args);
properties.setProperty("Ice.BatchAutoFlushSize", "100");
properties.setProperty("Ice.Trace.Dispatch", "1");
properties.setProperty("Ice.Trace.Protocol", "1");
properties.setProperty("Ice.Trace.Network", "3");
[communicator] = this.initialize(properties);
echo = new Test.EchoPrx(communicator, `__echo:${this.getTestEndpoint()}`);
const adapter = await communicator.createObjectAdapter("");
adapter.add(new MyDerivedClassI(echo.ice_getEndpoints()), Ice.stringToIdentity("test"));
await echo.setConnection();
echo.ice_getCachedConnection().setAdapter(adapter);
this.serverReady();
await communicator.waitForShutdown();
}
finally {
if (echo) {
await echo.shutdown();
}
if (communicator) {
await communicator.destroy();
}
}
}
}
|