本文整理汇总了TypeScript中@jonggrang/avar.putAVar函数的典型用法代码示例。如果您正苦于以下问题:TypeScript putAVar函数的具体用法?TypeScript putAVar怎么用?TypeScript putAVar使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了putAVar函数的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。
示例1: test
test('FIFO semantics for the waiters', function* () {
const qsem: Q.QSem = yield Q.newQSem(0);
const [t1, m1]: Forked<void> = yield fork(Q.waitQSem(qsem));
yield stop(t1, m1);
yield Q.signalQSem(qsem);
yield T.delay(10);
const [t2, m2]: Forked<void> = yield fork(Q.waitQSem(qsem));
yield T.delay(10);
const result: AV.AVar<boolean> = yield AV.newEmptyAVar;
const [t3, m3]: Forked<void> = yield fork(
T.onException(
Q.waitQSem(qsem),
AV.putAVar(result, false)
).chain(() => AV.putAVar(result, true))
);
yield Q.signalQSem(qsem);
yield T.delay(10);
yield stop(t2, m2);
yield stop(t3, m3);
const r: boolean = yield AV.takeAVar(result);
assert.ok(r);
return T.pure(void 0);
});
开发者ID:syaiful6,项目名称:jonggrang,代码行数:27,代码来源:qsem.ts
示例2:
return T.co(function* () {
const baton: AV.AVar<null> = yield AV.newEmptyAVar;
yield T.forkTask(T.forever(T.co(function* () {
yield AV.takeAVar(baton);
yield T.apathize(settings.action);
return T.delay(settings.frequency);
})));
return T.pure(AV.putAVar(baton, null));
});
开发者ID:syaiful6,项目名称:jonggrang,代码行数:9,代码来源:debounce.ts
示例3: co
return co(function* () {
yield takeAVar(needsRunning);
const a: A = yield maybe(set.task, identity, applyMaybe(modify, ma)) as Task<A>;
yield writeRef(currRef, right(a));
yield putAVar(responseVar, a);
yield delay(set.delay);
const responseVar_: AVar<A> = yield newEmptyAVar;
yield writeRef(currRef, left(responseVar_));
return loop(responseVar_, just(a));
});
开发者ID:syaiful6,项目名称:jonggrang,代码行数:10,代码来源:auto-update.ts
示例4:
return AV.newEmptyAVar.chain(avar =>
T.forkTask(T.ensure(t, AV.putAVar(avar, void 0))).chain(fib =>
T.delay(10).map(() => [fib, avar] as [T.Fiber<A>, AV.AVar<void>])
)
开发者ID:syaiful6,项目名称:jonggrang,代码行数:4,代码来源:utils.ts
示例5: pure
return pure(readRef(currRef).chain(mv => {
return isLeft(mv) ? putAVar(needsRunning, null).chain(() => readAVar(mv.value))
/* otherwise */ : pure(mv.value);
}));
开发者ID:syaiful6,项目名称:jonggrang,代码行数:4,代码来源:auto-update.ts
示例6:
AV.tryTakeAVar(msem.headWait).chain(extraFlags =>
P.isNothing(extraFlags) ? T.pure(quantity)
: /* otherwise */ AV.putAVar(msem.headWait, void 0).map(() => quantity + 1)
开发者ID:syaiful6,项目名称:jonggrang,代码行数:3,代码来源:qsem.ts
示例7: ChannelItem
.chain(oldHole =>
T.apSecond(
AV.putAVar(oldHole, new ChannelItem(val, newHole)),
AV.putAVar(chan.write, newHole)
)
开发者ID:syaiful6,项目名称:jonggrang,代码行数:5,代码来源:chan.ts
示例8:
).chain(() => AV.putAVar(result, true))
开发者ID:syaiful6,项目名称:jonggrang,代码行数:1,代码来源:qsem.ts
注:本文中的@jonggrang/avar.putAVar函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论