本文整理汇总了TypeScript中most.periodic函数的典型用法代码示例。如果您正苦于以下问题:TypeScript periodic函数的具体用法?TypeScript periodic怎么用?TypeScript periodic使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了periodic函数的3个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。
示例1: test
test('most: proxy$ should stop emitting when proxied$ unsubscribed', (t) => {
let target$ = most.periodic(1)
let proxy$ = proxy()
let proxied$ = proxy$.proxy(target$)
let emitted = 0
proxy$.subscribe({
next: () => {
emitted++
},
error: () => { },
complete: () => { }
})
let listener = {
next: () => {
if (emitted === 2) {
sub.unsubscribe()
}
},
error: () => { },
complete: () => { }
}
let sub = proxied$.subscribe(listener)
// target may still be subscribed
target$.subscribe(emptyListener)
setTimeout(() => {
//t.equal(emitted, 2)
t.ok(emitted === 2 || emitted === 3)
t.end()
}, 50)
})
开发者ID:whitecolor,项目名称:cycle-circular,代码行数:34,代码来源:most.ts
示例2: it
it('should not work after has been disposed', function(done) {
const number$ = most
.periodic(50, 1)
.scan((x, y) => x + y, 0)
.map(i => i + 1);
function app(_sources: any) {
return {other: number$};
}
const {sources, run} = setup(app, {
other: (num$: xsStream<number>) => most.from(num$).map(num => 'x' + num),
});
let dispose: any;
sources.other
.observe((x: any) => {
assert.notStrictEqual(x, 'x3');
if (x === 'x2') {
dispose();
setTimeout(() => {
done();
}, 100);
}
})
.catch(done);
dispose = run();
});
开发者ID:,项目名称:,代码行数:25,代码来源:
示例3: it
it('creates a circular dependency', (done) => {
const { attach, stream } = proxy();
const original = periodic(10, 1).scan((x, y) => x + y, 0);
attach(original);
stream.take(3).observe(assertExpected([0, 1, 2], done));
});
开发者ID:mostjs-community,项目名称:most-proxy,代码行数:9,代码来源:index.ts
注:本文中的most.periodic函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论