TypeScript operators.bufferCount函数代码示例

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

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

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

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

示例1: it

  it('should convert observable obeject to ordinal object', done => {
    const aValue = new Subject();
    const bValue = new Subject();
    const BUFFER_COUNT = 4;

    const values = createObject(
      aValue.pipe(startWith('')),
      bValue.pipe(startWith('')),
    );

    subscription.add(
      combineTemplate(values)
        .pipe(bufferCount(BUFFER_COUNT))
        .subscribe(v => {
          /*tslint:disable:no-magic-numbers*/
          expect(v[0]).to.be.deep.eq(createObject('', ''));
          expect(v[1]).to.be.deep.eq(createObject('200', ''));
          expect(v[2]).to.be.deep.eq(createObject('200', '300'));
          expect(v[3]).to.be.deep.eq(createObject('OK', '300'));
          /*tslint:enable:no-magic-numbers*/
          done();
        }),
    );

    aValue.next('200');
    bValue.next('300');
    aValue.next('OK');
  });

开发者ID:brn，项目名称:react-mvi，代码行数:28，代码来源:combine-template.spec.ts

示例2: updatebyPlacements

	updatebyPlacements(placementIDs: string): void {
		const source = Observable.create((observer) => {
			let placementIDsArray = lo_.uniq(placementIDs.split(','))
			const next = () => {
				const placementID = parseInt(placementIDsArray.shift(), 10)
				if (!placementID) {
					placementIDsArray.length > 0 && next() || observer.complete()
					return
				}
				this.sizmekApiClient.getMultipleResult<any>(this.sizmekApiClient.getAdsByPlacement, placementID)
				.subscribe((data) => {
					lo_.forEach(data.result, value => observer.next(value))
					next()
				}, (error) => {
					this.notifications.notify('error', error.message, !0)
				})
			}
			next()
		})
		source
		.pipe(bufferCount(10))
		.subscribe((value) => {
			this.sizmekApiClient.updateAds({entities: value}).subscribe(() => {
				this.notifications.notify('success', `Calling updateAds for adIds ${ reduceFrom<number, any, 'id'>(value, 'id').join(', ') } success`, !0)
			}, (error) => {
				this.notifications.notify('error', error.message, !0)
			})
		})
	}

开发者ID:marsojane，项目名称:sasutil，代码行数:29，代码来源:adsupdate.service.ts

示例3: bufferCount2

 bufferCount2() {
   // Create an observable that emits a value every second
   const source = interval(1000);
   /*
     bufferCount also takes second argument, when to start the next buffer
     for instance, if we have a bufferCount of 3 but second argument (startBufferEvery) of 1:
     1st interval value:
     buffer 1: [0]
     2nd interval value:
     buffer 1: [0,1]
     buffer 2: [1]
     3rd interval value:
     buffer 1: [0,1,2] Buffer of 3, emit buffer
     buffer 2: [1,2]
     buffer 3: [2]
     4th interval value:
     buffer 2: [1,2,3] Buffer of 3, emit buffer
     buffer 3: [2, 3]
     buffer 4: [3]
   */
   const bufferEveryOne = source.pipe(bufferCount(3, 1));
   // Print values to console
   const subscribe = bufferEveryOne.subscribe(val =>
     console.log('Start Buffer Every 1:', val)
   );
 }

开发者ID:zwvista，项目名称:SampleMisc，代码行数:26，代码来源:transforming.service.ts

示例4: it

    it('observe request with multiple observable emissions', async () => {
        const [serverTransports, clientTransports] = createMessageTransports()
        const server = createConnection(serverTransports)
        server.onRequest(
            'm',
            (params: number[]) =>
                new Observable<number>(observer => {
                    for (const v of params) {
                        observer.next(v + 1)
                    }
                    observer.complete()
                })
        )
        server.listen()

        const client = createConnection(clientTransports)
        client.listen()
        assert.deepStrictEqual(
            await client
                .observeRequest<number>('m', [1, 2, 3, 4])
                .pipe(bufferCount(4))
                .toPromise(),
            [2, 3, 4, 5]
        )
    })

开发者ID:JoYiRis，项目名称:sourcegraph，代码行数:25，代码来源:connection.test.ts

示例5: it

  it('should raise error if source raise error before reaching specified buffer count', () => {
    const e1 =   hot('--a--b--c--d--#');
    const e1subs =   '^             !';
    const expected = '--------------#';

    expectObservable(e1.pipe(bufferCount(5))).toBe(expected);
    expectSubscriptions(e1.subscriptions).toBe(e1subs);
  });

开发者ID:DallanQ，项目名称:rxjs，代码行数:8，代码来源:bufferCount-spec.ts

示例6: getCoordinates

 getCoordinates(): Observable<{first: Coordinates; second: Coordinates}> {
   return this.asObservable().pipe(
     bufferCount(2),
     map(buffer => {
       return {first: buffer[0], second: buffer[1]};
     }),
   );
 }

开发者ID:thelgevold，项目名称:angular-2-samples，代码行数:8，代码来源:edge-service.ts

示例7: bufferCount1

 bufferCount1() {
   // Create an observable that emits a value every second
   const source = interval(1000);
   // After three values are emitted, pass on as an array of buffered values
   const bufferThree = source.pipe(bufferCount(3));
   // Print values to console
   // ex. output [0,1,2]...[3,4,5]
   const subscribe = bufferThree.subscribe(val =>
     console.log('Buffered Values:', val)
   );
 }

开发者ID:zwvista，项目名称:SampleMisc，代码行数:11，代码来源:transforming.service.ts

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