TypeScript nats-hemera.ready函数代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› TypeScript›TypeScript教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了TypeScript中nats-hemera.ready函数的典型用法代码示例。如果您正苦于以下问题：TypeScript ready函数的具体用法？TypeScript ready怎么用？TypeScript ready使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了ready函数的4个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1: it

    it('Should be able to add two numbers', function (done) {
        const nats = require('nats').connect();

        const hemera = new Hemera(nats, { logLevel: 'info' });
        hemera.use(Plugin1);

        hemera.ready(() => {
            hemera.ext('onServerPreRequest', async function (ctx, req, res) {
                await Promise.resolve();
            });

            hemera.act({
                topic,
                cmd: 'add',
                a: 1,
                b: 0,
            }, async function (err, resp) {
                try {
                    await resp;
                    expect(err).toBeNull();
                    expect(resp.result).toEqual(1);
                    hemera.close(done);
                } catch (err) {
                    hemera.close(done.fail);
                }

            });
        });

    });

开发者ID:baotaizhang，项目名称:fullstack-pro，代码行数:30，代码来源:example-asyncplugin.test.ts

示例2: Hemera

 server = HemeraTestSuite.start_server(PORT, () => {
     const nats = Nats.connect(authUrl);
     hemera = new Hemera(nats, {});
     hemera.use(require('hemera-safe-promises'));
     hemera.use(HemeraSqlStore, {
         knex: {
             dialect: 'mysql',
             connection: {
                 host: process.env.DB_HOST,
                 user: process.env.DB_USER,
                 password: process.env.DB_PASSWORD,
                 database: testDatabase,
             },
             pool: {
                 min: 0,
                 max: 7,
             },
         },
     });
     hemera.ready(async () => {
         await createCounter(hemera.sqlStore.useDb(testDatabase));
         repo = new CounterRemoteRepository(hemera);
         done();
     });
 });

开发者ID:baotaizhang，项目名称:fullstack-pro，代码行数:25，代码来源:counter-hemera-repository.test.ts

示例3: Hemera

import * as Hemera from 'nats-hemera';
const nats = {};
const hemera: any = new Hemera(nats, {});
hemera.ready(() => {
  hemera.add({
    topic: 'math',
    cmd: 'add'
  }, (req: any, cb: any) => {
  });
});

开发者ID:AbraaoAlves，项目名称:DefinitelyTyped，代码行数:10，代码来源:nats-hemera-tests.ts

示例4: catch

            dialect: process.env.DB_TYPE,
            connection: {
                host: process.env.DB_HOST,
                user: process.env.DB_USER,
                password: process.env.DB_PASSWORD,
                database: process.env.DB_DATABASE,
            },
        },
    });
    hemera.use(HemeraZipkin, {
        host: process.env.ZIPKIN_URL,
        port: process.env.ZIPKIN_PORT,
        sampling: 1,
    });
    hemera.use(ContainerHemera, {
    });

    // hemera.setOption('payloadValidator', 'hemera-joi');

    hemera.ready(() => {
        // let Joi = hemera.exposition['hemera-joi'].joi;


    });
} catch (err) {
    logger.error('hemera publish was failed due to ');
    logger.error(err);
}

开发者ID:baotaizhang，项目名称:fullstack-pro，代码行数:28，代码来源:index.ts

注：本文中的nats-hemera.ready函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。