TypeScript kefir.merge函数代码示例

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

原作者: [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；未经允许，请勿转载。