1 | ;
|
2 | Object.defineProperty(exports, "__esModule", { value: true });
|
3 | const ava_1 = require("ava");
|
4 | const index_1 = require("../index");
|
5 | const util_1 = require("./fixtures/util");
|
6 | const funcs = require("./fixtures/worker");
|
7 | async function testWorker(t, provider, options) {
|
8 | const opts = {
|
9 | timeout: 10,
|
10 | gc: "off",
|
11 | description: t.title,
|
12 | ...options
|
13 | };
|
14 | const faastModule = await (0, index_1.faast)(provider, funcs, opts);
|
15 | const remote = faastModule.functions;
|
16 | try {
|
17 | t.is(await remote.runWorker("All"), "All done");
|
18 | }
|
19 | finally {
|
20 | await faastModule.cleanup();
|
21 | }
|
22 | }
|
23 | for (const provider of index_1.providers.filter(p => p !== "google")) {
|
24 | for (const config of [{ childProcess: true }, { childProcess: false }]) {
|
25 | (0, ava_1.default)((0, util_1.title)(provider, `node worker thread`, config), testWorker, provider, config);
|
26 | }
|
27 | }
|
28 | //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoid29ya2VyLnRlc3QuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi90ZXN0L3dvcmtlci50ZXN0LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsNkJBQTZDO0FBQzdDLG9DQUFxRTtBQUNyRSwwQ0FBd0M7QUFDeEMsMkNBQTJDO0FBRTNDLEtBQUssVUFBVSxVQUFVLENBQ3JCLENBQW1CLEVBQ25CLFFBQWtCLEVBQ2xCLE9BQXNCO0lBRXRCLE1BQU0sSUFBSSxHQUFrQjtRQUN4QixPQUFPLEVBQUUsRUFBRTtRQUNYLEVBQUUsRUFBRSxLQUFLO1FBQ1QsV0FBVyxFQUFFLENBQUMsQ0FBQyxLQUFLO1FBQ3BCLEdBQUcsT0FBTztLQUNiLENBQUM7SUFDRixNQUFNLFdBQVcsR0FBRyxNQUFNLElBQUEsYUFBSyxFQUFDLFFBQVEsRUFBRSxLQUFLLEVBQUUsSUFBSSxDQUFDLENBQUM7SUFDdkQsTUFBTSxNQUFNLEdBQUcsV0FBVyxDQUFDLFNBQVMsQ0FBQztJQUVyQyxJQUFJO1FBQ0EsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxNQUFNLE1BQU0sQ0FBQyxTQUFTLENBQUMsS0FBSyxDQUFDLEVBQUUsVUFBVSxDQUFDLENBQUM7S0FDbkQ7WUFBUztRQUNOLE1BQU0sV0FBVyxDQUFDLE9BQU8sRUFBRSxDQUFDO0tBQy9CO0FBQ0wsQ0FBQztBQUVELEtBQUssTUFBTSxRQUFRLElBQUksaUJBQVMsQ0FBQyxNQUFNLENBQUMsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxDQUFDLEtBQUssUUFBUSxDQUFDLEVBQUU7SUFDMUQsS0FBSyxNQUFNLE1BQU0sSUFBSSxDQUFDLEVBQUUsWUFBWSxFQUFFLElBQUksRUFBRSxFQUFFLEVBQUUsWUFBWSxFQUFFLEtBQUssRUFBRSxDQUFDLEVBQUU7UUFDcEUsSUFBQSxhQUFJLEVBQUMsSUFBQSxZQUFLLEVBQUMsUUFBUSxFQUFFLG9CQUFvQixFQUFFLE1BQU0sQ0FBQyxFQUFFLFVBQVUsRUFBRSxRQUFRLEVBQUUsTUFBTSxDQUFDLENBQUM7S0FDckY7Q0FDSiIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB0ZXN0LCB7IEV4ZWN1dGlvbkNvbnRleHQgfSBmcm9tIFwiYXZhXCI7XG5pbXBvcnQgeyBDb21tb25PcHRpb25zLCBmYWFzdCwgUHJvdmlkZXIsIHByb3ZpZGVycyB9IGZyb20gXCIuLi9pbmRleFwiO1xuaW1wb3J0IHsgdGl0bGUgfSBmcm9tIFwiLi9maXh0dXJlcy91dGlsXCI7XG5pbXBvcnQgKiBhcyBmdW5jcyBmcm9tIFwiLi9maXh0dXJlcy93b3JrZXJcIjtcblxuYXN5bmMgZnVuY3Rpb24gdGVzdFdvcmtlcihcbiAgICB0OiBFeGVjdXRpb25Db250ZXh0LFxuICAgIHByb3ZpZGVyOiBQcm92aWRlcixcbiAgICBvcHRpb25zOiBDb21tb25PcHRpb25zXG4pIHtcbiAgICBjb25zdCBvcHRzOiBDb21tb25PcHRpb25zID0ge1xuICAgICAgICB0aW1lb3V0OiAxMCxcbiAgICAgICAgZ2M6IFwib2ZmXCIsXG4gICAgICAgIGRlc2NyaXB0aW9uOiB0LnRpdGxlLFxuICAgICAgICAuLi5vcHRpb25zXG4gICAgfTtcbiAgICBjb25zdCBmYWFzdE1vZHVsZSA9IGF3YWl0IGZhYXN0KHByb3ZpZGVyLCBmdW5jcywgb3B0cyk7XG4gICAgY29uc3QgcmVtb3RlID0gZmFhc3RNb2R1bGUuZnVuY3Rpb25zO1xuXG4gICAgdHJ5IHtcbiAgICAgICAgdC5pcyhhd2FpdCByZW1vdGUucnVuV29ya2VyKFwiQWxsXCIpLCBcIkFsbCBkb25lXCIpO1xuICAgIH0gZmluYWxseSB7XG4gICAgICAgIGF3YWl0IGZhYXN0TW9kdWxlLmNsZWFudXAoKTtcbiAgICB9XG59XG5cbmZvciAoY29uc3QgcHJvdmlkZXIgb2YgcHJvdmlkZXJzLmZpbHRlcihwID0+IHAgIT09IFwiZ29vZ2xlXCIpKSB7XG4gICAgZm9yIChjb25zdCBjb25maWcgb2YgW3sgY2hpbGRQcm9jZXNzOiB0cnVlIH0sIHsgY2hpbGRQcm9jZXNzOiBmYWxzZSB9XSkge1xuICAgICAgICB0ZXN0KHRpdGxlKHByb3ZpZGVyLCBgbm9kZSB3b3JrZXIgdGhyZWFkYCwgY29uZmlnKSwgdGVzdFdvcmtlciwgcHJvdmlkZXIsIGNvbmZpZyk7XG4gICAgfVxufVxuIl19 |
\ | No newline at end of file |