Refactoring for Asynchronous Initialization in Effect-Based Codebase

class UserSession {
  connected = Effect.runSync(SubscriptionRef.make(false))
  unsub!: () => void;

  constructor() {
    const listenChanges = this.connected.pipe(
      // do things
      Stream.runDrain
    )
    const fiber = Effect.runFork(listenChanges);
    this.unsub = () => Effect.runSync(Fiber.interruptFork(fiber))
  }

  onDestroy() {
    this.unsub();
  }
}

class UserSession2 {
  connected!: SubscriptionRef.SubscriptionRef<boolean>;
  unsub!: () => void;

  static async asyncMake() {
    const user = new UserSession();
    user.connected = await Effect.runPromise(SubscriptionRef.make(false));
    const listenChanges = user.connected.pipe(
      // do things
      Stream.runDrain
    )
    const fiber = Effect.runFork(listenChanges);
    user.unsub = () => Effect.runSync(Fiber.interruptFork(fiber));
    return user;
  }

  onDestroy() {
    this.unsub();
  }
}