Beta Shell v2.0

File Manager

~ /usr/local/lib/node_modules/@google/gemini-cli/node_modules/atomically/src/utils

Name	Size	Perms	Modified	Actions
[ .. / .. ]
lang.ts	588 B	-rw-r--r--	1985-10-26 08:15:00	Edit Del
scheduler.ts	829 B	-rw-r--r--	1985-10-26 08:15:00	Edit Del
temp.ts	2.72 KB	-rw-r--r--	1985-10-26 08:15:00	Edit Del

Editing: scheduler.ts (829 B)

/* IMPORT */

import type {Disposer} from '../types';

/* HELPERS */

const Queues: Record<string, Function[] | undefined> = {};

/* MAIN */

//TODO: Maybe publish this as a standalone package

const Scheduler = {

  /* API */

  next: ( id: string ): void => {

    const queue = Queues[id];

    if ( !queue ) return;

    queue.shift ();

    const job = queue[0];

    if ( job ) {

      job ( () => Scheduler.next ( id ) );

    } else {

      delete Queues[id];

    }

  },

  schedule: ( id: string ): Promise<Disposer> => {

    return new Promise ( resolve => {

      let queue = Queues[id];

      if ( !queue ) queue = Queues[id] = [];

      queue.push ( resolve );

      if ( queue.length > 1 ) return;

      resolve ( () => Scheduler.next ( id ) );

    });

  }

};

/* EXPORT */

export default Scheduler;