Effect CommunityEC
Effect Community•2y ago•
2 replies
donverduyn

Resolving TS Errors Caused by Race Condition in getBus Function

I'm currently facing TS errors which seem to be caused by a race condition. Whenever i change the file and change it back to the correct state after some pause, the error goes away. The error happens because the return type of getBus cannot be inferred. Anybody familiar with this?

getBus is a function that returns a promise with the result of the layer. The reason for accessing the bus through the promise is to access it from a different runtime at the module level. For reference: https://github.com/DonnyVerduijn/milight-ui/blob/master/src/common/hooks/useRuntimeFn.ts

const useMessageBus = () => {
  const getBus = useRuntimeFn(AppRuntime, MessageBus);

  const publish = useRuntimeFn(
    AppRuntime,
    flow((message: string) =>
      Effect.gen(function* () {
        const bus = yield* MessageBus;
        yield* bus.publish({ message, payload: message });
      })
    )
  );

  void useRuntime(
    AppRuntime,
    Effect.scoped(
      Effect.gen(function* () {
        const bus = yield* Effect.promise(getBus);
        const dequeue = yield* bus.subscribe;
        const message = yield* Queue.take(dequeue);
        console.log('log', message);
      }).pipe(Effect.forever)
    )
  );
  return { publish };
};
Was this page helpful?