TypeScript task.co函数代码示例

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

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

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

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

示例1: get

 get(sessId: string) {
   const self = this;
   return T.co(function* () {
     yield self.addMockOperation({ tag: 'get', id: sessId });
     return RV.readRef(self.sessions).map(sessions => sessId in sessions ? sessions[sessId] : null);
   });
 }

开发者ID:syaiful6，项目名称:jonggrang，代码行数:7，代码来源:utils.ts

示例2: co

export function mkAutoUpdateHelper<A>(
  set: UpdateSettings<A>,
  modify: Maybe<(_: A) => Task<A>>
): Task<Task<A>> {
  return co(function* () {
    let needsRunning: AVar<null> = yield newEmptyAVar;
    let responseVar0: AVar<A> = yield newEmptyAVar;
    let currRef: Ref<Either<AVar<A>, A>> = yield newRef(left(responseVar0));
    function loop(responseVar: AVar<A>, ma: Maybe<A>): Task<void> {
      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));
      });
    }
    yield forkTask(loop(responseVar0, nothing));

    return pure(readRef(currRef).chain(mv => {
      return isLeft(mv)  ? putAVar(needsRunning, null).chain(() => readAVar(mv.value))
        /* otherwise */  : pure(mv.value);
    }));
  });
}

开发者ID:syaiful6，项目名称:jonggrang，代码行数:28，代码来源:auto-update.ts

示例3: destroy

 destroy(sessId: string) {
   const self = this;
   return T.co(function* () {
     yield RV.modifyRef(self.sessions, sess => SO.remove(sessId, sess) as any);
     return self.addMockOperation({ tag: 'destroy', id: sessId });
   });
 }

开发者ID:syaiful6，项目名称:jonggrang，代码行数:7，代码来源:utils.ts

示例4: it

  it('storage.replace should throws an exception if a session doesnt exist', function* () {
    return replicateA_(10, T.co(function* () {
      const s: Session = yield generateSession(HasAuthId.HAS_AUTH_ID);
      const sid = s.id;
      const exi: Session | null = yield run(storage.get(sid));
      assert.ok(!exi);
      const ret: Either<SessionDoesNotExist, void> = yield T.attemptJust(
        run(storage.replace(s)), selectSessionNotExis);
      assert.ok(isLeft(ret));
      assert.deepEqual((ret.value as SessionDoesNotExist).newSession, s);
      // test that session not saved
      const exi2: Session | null = yield run(storage.get(sid));
      assert.ok(!exi2);

      yield run(storage.insert(s));
      const s2: Session | null = yield run(storage.get(sid));
      assert.deepEqual(s2, s);

      const s3 = createSession(sid, null, s.data, s.createdAt, s.accessedAt);
      yield run(storage.replace(s3));
      const s4: Session | null = yield run(storage.get(sid));
      assert.deepEqual(s4, s3);
      return T.pure(true);
    }));
  });

开发者ID:syaiful6，项目名称:jonggrang，代码行数:25，代码来源:storage-test.ts

示例5: destroyAllOfAuthId

 destroyAllOfAuthId(authId: string) {
   const self = this;
   return T.co(function* () {
     yield RV.modifyRef(self.sessions, sess => filterSM(sess, s => s.authId !== authId));
     return self.addMockOperation({ authId, tag: 'destroyAllOfAuthId' });
   });
 }

开发者ID:syaiful6，项目名称:jonggrang，代码行数:7，代码来源:utils.ts

示例6: run

 return T.forIn(zip([s1].concat(sys), sys), ([before, after]) => T.co(function* () {
   const ex = yield run(storage.get(sid));
   assert.deepEqual(ex, before);
   yield run(storage.replace(after));
   const ex2 = yield run(storage.get(sid));
   assert.deepEqual(ex2, after);
   return T.pure(void 0);
 }));

开发者ID:syaiful6，项目名称:jonggrang，代码行数:8，代码来源:storage-test.ts

示例7:

 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

示例8: debounceTask

export function debounceTask(settings: DebounceSettings): T.Task<T.Task<void>> {
  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，代码行数:11，代码来源:debounce.ts

示例9: loop

 function loop(responseVar: AVar<A>, ma: Maybe<A>): Task<void> {
   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，代码行数:12，代码来源:auto-update.ts

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