import type { EIO } from "../../Task/model";
import type { XPromise } from "../model";
import { Done } from "../state";

/**
 * Unsafe version of done
 */
export const unsafeDone = <E, A>(io: EIO<E, A>) => (promise: XPromise<E, A>) => {
   const state = promise.state.get;

   if (state._tag === "Pending") {
      promise.state.set(new Done(io));

      Array.from(state.joiners)
         .reverse()
         .forEach((f) => {
            f(io);
         });
   }
};