Integrating Effect-RX with X-State: Seeking Guidance and Sharing Current Implementation

import type * as Layer from 'effect/Layer';
import type * as ManagedRuntime from 'effect/ManagedRuntime';
import type { AuthClientService } from '@/features/auth/services/auth';
import type { ApiClient } from '../common/api-client';
import type { InspectorService } from '../state-inspector/inspector';

export type LiveLayerType = Layer.Layer<
  ApiClient | AuthClientService | InspectorService
>;

export type LiveManagedRuntime = ManagedRuntime.ManagedRuntime<
  Layer.Layer.Success<LiveLayerType>,
  never
>;

export type LiveRuntimeContext =
  ManagedRuntime.ManagedRuntime.Context<LiveManagedRuntime>;

import type * as Cause from 'effect/Cause';
import * as Duration from 'effect/Duration';
import * as Effect from 'effect/Effect';
import type * as Schedule from 'effect/Schedule';
import { fromPromise } from 'xstate';
import type { AuthClientService } from '@/features/auth/services/auth';
import type { ApiClient } from '../services/common/api-client';
import type { LiveManagedRuntime } from '../services/runtime/runtime-live';
import type { InspectorService } from '../services/state-inspector/inspector';

export interface BaseActorInput {
  runtime: LiveManagedRuntime;
}

export interface EffectActorConfig {
  span?: string;
  timeout?: Duration.DurationInput;
  retrySchedule?: Schedule.Schedule<unknown>;
  logErrors?: boolean;
}