• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

TypeScript kefir.merge函数代码示例

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

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



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

示例1:

 const delta2 = sinon.spy(action$ =>
   Kefir.merge([
     action$
       .thru(ofType('FIRST_REQUEST'))
       .map(() => ({ type: 'FIRST_RESPONSE' })),
     action$
       .thru(ofType('SECOND_REQUEST'))
       .map(() => ({ type: 'SECOND_RESPONSE' }))
   ])
开发者ID:valtech-nyc,项目名称:brookjs,代码行数:9,代码来源:observeDelta.spec.ts


示例2: new

  return store => {
    const action$: Stream<A, never> = new (Kefir as any).Stream().setName(
      'action$'
    );
    const state$: Property<S, never> = new (Kefir as any).Stream()
      .toProperty(store.getState)
      .setName('state$');

    let emitting = false;
    let queue: A[] = [];

    (store as any).subscription = Kefir.merge(
      sources.map(source => source(action$, state$))
    ).observe({
      error(err) {
        // eslint-disable-next-line no-console
        console.error('Error emitted into delta', err);
      },
      value(value) {
        if (emitting) {
          queue.push(value);
        } else {
          store.dispatch(value);
        }
      }
    });

    return next => action => {
      const result = next(action);
      const state = store.getState();

      emitting = true;

      (state$ as any)._emitValue(state);
      (action$ as any)._emitValue(result);

      emitting = false;

      if (queue.length) {
        const run = queue;
        queue = [];

        for (const action of run) {
          store.dispatch(action);
        }
      }

      return result;
    };
  };
开发者ID:valtech-nyc,项目名称:brookjs,代码行数:50,代码来源:observeDelta.ts


示例3:

		let a: Stream<number, void> = Kefir.sequentially(100, [1, 3]);
		let b: Stream<number, void> = Kefir.sequentially(100, [2, 4]).delay(40);
		let c: Stream<number, void> = Kefir.sequentially(60, [5, 6, 7]);
		let observable02: Observable<number, void> = Kefir.combine<number, void, number>([a, b], [c], (a, b, c) => a + b + c);
	}
	{
		let a: Stream<number, void> = Kefir.sequentially(100, [0, 1, 2, 3]);
		let b: Stream<number, void> = Kefir.sequentially(160, [4, 5, 6]);
		let c: Property<number, void> = Kefir.sequentially(100, [8, 9]).delay(260).toProperty(() => 7);
		let observable03: Observable<number, void> = Kefir.zip<number, void, number>([a, b, c]);
	}
	{
		let a: Stream<number, void> = Kefir.sequentially(100, [0, 1, 2]);
		let b: Stream<number, void> = Kefir.sequentially(100, [0, 1, 2]).delay(30);
		let c: Stream<number, void> = Kefir.sequentially(100, [0, 1, 2]).delay(60);
		let abc: Observable<number, void> = Kefir.merge<number, void>([a, b, c]);
	}
	{
		let a: Stream<number, void> = Kefir.sequentially(100, [0, 1, 2]);
		let b: Stream<number, void> = Kefir.sequentially(100, [3, 4, 5]);
		let abc: Observable<number, void> = Kefir.concat<number, void>([a, b]);
	}
	{
		let a: Stream<number, void> = Kefir.sequentially(100, [0, 1, 2]);
		let b: Stream<number, void> = Kefir.sequentially(100, [0, 1, 2]).delay(30);
		let c: Observable<number, void> = Kefir.sequentially(100, [0, 1, 2]).delay(60);
		let pool: ObservablePool<number, void> = Kefir.pool<number, void>();
		pool.plug(a);
		pool.plug(b);
		pool.plug(c);
	}
开发者ID:ErykB2000,项目名称:DefinitelyTyped,代码行数:31,代码来源:kefir-tests.ts



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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
TypeScript kefir.pool函数代码示例发布时间:2022-05-25
下一篇:
TypeScript kefir.interval函数代码示例发布时间:2022-05-25
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap