/**
 * The `Fiber` module provides operations for handles returned by forking
 * effects. A `Fiber<A, E>` is a lightweight runtime execution of an `Effect`
 * that may still be running, may already have completed, and can be observed or
 * interrupted by other fibers.
 *
 * Applications create fibers with operations such as `Effect.forkChild`,
 * `Effect.forkScoped`, `Effect.forkIn`, or `Effect.forkDetach`, then use this
 * module to wait for results, inspect exits, or cancel work that is no longer
 * needed.
 *
 * **Mental model**
 *
 * - A fiber is a handle to a running or completed effect, not the effect itself
 * - {@link await_ await} observes completion as an `Exit` without failing the current
 *   effect
 * - {@link join} waits for success and propagates the fiber's failure into the
 *   current effect
 * - {@link interrupt} requests cancellation and waits until the target fiber
 *   finishes running finalizers
 * - Group operations such as {@link awaitAll}, {@link joinAll}, and
 *   {@link interruptAll} apply the same ideas to collections of fibers
 *
 * **Common tasks**
 *
 * - Wait for one fiber with {@link await_ await} or {@link join}
 * - Wait for many fibers with {@link awaitAll} or {@link joinAll}
 * - Stop work with {@link interrupt}, {@link interruptAs},
 *   {@link interruptAll}, or {@link interruptAllAs}
 * - Recognize fiber handles with {@link isFiber}
 * - Link a manually managed fiber to a `Scope` with {@link runIn}
 *
 * **Gotchas**
 *
 * - `await` gives you an `Exit`; use `join` when the current effect should fail
 *   if the fiber failed
 * - Interruption is cooperative, so a fiber can continue through
 *   uninterruptible regions and finalizers before it finishes
 * - `joinAll` stops waiting on the first failure, but it does not interrupt the
 *   remaining fibers for you
 *
 * **Example** (Joining a forked effect)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   const fiber = yield* Effect.forkChild(Effect.succeed(42))
 *   const value = yield* Fiber.join(fiber)
 *
 *   return value
 * })
 * ```
 *
 * @since 2.0.0
 */
import type * as Arr from "./Array.ts"
import type * as Context from "./Context.ts"
import type { Effect } from "./Effect.ts"
import type { Exit } from "./Exit.ts"
import * as effect from "./internal/effect.ts"
import { version } from "./internal/version.ts"
import type { LogLevel } from "./LogLevel.ts"
import type { Pipeable } from "./Pipeable.ts"
import { hasProperty } from "./Predicate.ts"
import type { StackFrame } from "./References.ts"
import type { Scheduler, SchedulerDispatcher } from "./Scheduler.ts"
import type { Scope } from "./Scope.ts"
import type { AnySpan } from "./Tracer.ts"
import type { Covariant } from "./Types.ts"

const TypeId = `~effect/Fiber/${version}`

/**
 * A runtime fiber is a lightweight thread that executes Effects. Fibers are
 * the unit of concurrency in Effect. They provide a way to run multiple
 * Effects concurrently while maintaining structured concurrency and
 * cancellation safety.
 *
 * **When to use**
 *
 * Use to observe, join, interrupt, or coordinate work that has already been
 * forked.
 *
 * **Details**
 *
 * A fiber exposes both safe Effect-based operations, such as {@link await_ await},
 * {@link join}, and {@link interrupt}, and low-level runtime fields used by
 * the scheduler and runtime internals.
 *
 * **Gotchas**
 *
 * Prefer the exported functions in this module over calling `interruptUnsafe`
 * or `pollUnsafe` directly. The unsafe methods are immediate runtime hooks and
 * do not provide the same Effect-based sequencing guarantees.
 *
 * **Example** (Awaiting a forked fiber)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   // Fork an effect to run in a new fiber
 *   const fiber = yield* Effect.forkChild(Effect.succeed(42))
 *
 *   // Wait for the fiber to complete and get its result
 *   const result = yield* Fiber.await(fiber)
 *   console.log(result) // Exit.succeed(42)
 *
 *   return result
 * })
 * ```
 *
 * @category models
 * @since 2.0.0
 */
export interface Fiber<out A, out E = never> extends Pipeable {
  readonly [TypeId]: Fiber.Variance<A, E>

  readonly id: number
  readonly currentOpCount: number
  readonly getRef: <A>(ref: Context.Reference<A>) => A
  readonly context: Context.Context<never>
  setContext(context: Context.Context<never>): void
  readonly currentScheduler: Scheduler
  readonly currentDispatcher: SchedulerDispatcher
  readonly currentSpan?: AnySpan | undefined
  readonly currentLogLevel: LogLevel
  readonly minimumLogLevel: LogLevel
  readonly currentStackFrame?: StackFrame | undefined
  readonly maxOpsBeforeYield: number
  readonly currentPreventYield: boolean
  readonly addObserver: (cb: (exit: Exit<A, E>) => void) => () => void
  readonly interruptUnsafe: (
    fiberId?: number | undefined,
    annotations?: Context.Context<never> | undefined
  ) => void
  readonly pollUnsafe: () => Exit<A, E> | undefined
}

/**
 * The Fiber namespace contains utility types and functions for working with fibers.
 * It provides type-level utilities for fiber operations and variance encoding.
 *
 * **When to use**
 *
 * Use to reference type-level helpers associated with `Fiber`.
 *
 * **Details**
 *
 * The namespace currently exposes type-level support used by the `Fiber`
 * interface. Runtime operations are exported as module-level functions.
 *
 * **Example** (Working with fiber types)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   // Create a fiber
 *   const fiber = yield* Effect.forkChild(Effect.succeed(42))
 *
 *   // Use namespace types for variance
 *   const typedFiber: Fiber.Fiber<number, never> = fiber
 *
 *   // Access fiber properties
 *   console.log(`Fiber ID: ${fiber.id}`)
 *
 *   // Join the fiber
 *   const result = yield* Fiber.join(fiber)
 *   return result // 42
 * })
 * ```
 *
 * @since 2.0.0
 */
export declare namespace Fiber {
  /**
   * Variance encoding for the Fiber type, specifying covariance in both the
   * success type `A` and the error type `E`.
   *
   * **When to use**
   *
   * Use to carry the success and error type parameters for `Fiber` in Effect's
   * type machinery.
   *
   * **Example** (Upcasting fibers safely)
   *
   * ```ts
   * import type { Fiber } from "effect"
   *
   * // Variance allows safe subtyping
   * declare const fiber: Fiber.Fiber<number, Error>
   * const upcast: Fiber.Fiber<unknown, unknown> = fiber
   * ```
   *
   * @category models
   * @since 2.0.0
   */
  export interface Variance<out A, out E = never> {
    readonly _A: Covariant<A>
    readonly _E: Covariant<E>
  }
}

const await_: <A, E>(self: Fiber<A, E>) => Effect<Exit<A, E>> = effect.fiberAwait
export {
  /**
   * Waits for a fiber to complete and returns its exit value.
   *
   * **When to use**
   *
   * Use when you need to inspect whether the fiber succeeded,
   * failed, died, or was interrupted without propagating the failure.
   *
   * **Details**
   *
   * The returned Effect always succeeds with an `Exit` describing the fiber's
   * outcome.
   *
   * **Gotchas**
   *
   * This does not flatten the fiber result into the current Effect. Use
   * {@link join} when you want fiber failures to fail the current Effect.
   *
   * **Example** (Awaiting a fiber exit)
   *
   * ```ts
   * import { Effect, Fiber } from "effect"
   *
   * const program = Effect.gen(function*() {
   *   const fiber = yield* Effect.forkChild(Effect.succeed(42))
   *   const exit = yield* Fiber.await(fiber)
   *   console.log(exit) // Exit.succeed(42)
   * })
   * ```
   *
   * @category combinators
   * @since 2.0.0
   */
  await_ as await
}
/**
 * Waits for all fibers in the provided iterable to complete and returns
 * an array of their exit values.
 *
 * **When to use**
 *
 * Use when you need every fiber outcome as data, including failures and
 * interruptions.
 *
 * **Details**
 *
 * The returned array is ordered like the input iterable.
 *
 * **Gotchas**
 *
 * Failures are captured as `Exit.Failure` values. Use {@link joinAll} when you
 * want the first failed fiber to fail the returned Effect.
 *
 * **Example** (Awaiting multiple fiber exits)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   const fiber1 = yield* Effect.forkChild(Effect.succeed(1))
 *   const fiber2 = yield* Effect.forkChild(Effect.succeed(2))
 *   const exits = yield* Fiber.awaitAll([fiber1, fiber2])
 *   console.log(exits) // [Exit.succeed(1), Exit.succeed(2)]
 * })
 * ```
 *
 * @category combinators
 * @since 2.0.0
 */
export const awaitAll: <A extends Fiber<any, any>>(
  self: Iterable<A>
) => Effect<
  Array<
    Exit<
      A extends Fiber<infer _A, infer _E> ? _A : never,
      A extends Fiber<infer _A, infer _E> ? _E : never
    >
  >
> = effect.fiberAwaitAll

/**
 * Joins a fiber, blocking until it completes. If the fiber succeeds,
 * returns its value. If it fails, the error is propagated.
 *
 * **When to use**
 *
 * Use when the forked fiber is part of the current workflow and
 * its failure should fail the current Effect.
 *
 * **Gotchas**
 *
 * Joining a failed fiber propagates the fiber's Cause. Use {@link await_ await} when
 * you need to inspect the `Exit` instead of failing.
 *
 * **Example** (Joining a fiber)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   const fiber = yield* Effect.forkChild(Effect.succeed(42))
 *   const result = yield* Fiber.join(fiber)
 *   console.log(result) // 42
 * })
 * ```
 *
 * @see {@link await_ await} for inspecting the fiber outcome as an Exit
 *
 * @category combinators
 * @since 2.0.0
 */
export const join: <A, E>(self: Fiber<A, E>) => Effect<A, E> = effect.fiberJoin

/**
 * Waits for all fibers to succeed and returns their values in input order.
 *
 * **When to use**
 *
 * Use when every fiber must succeed and you want the successful values rather
 * than the `Exit` values.
 *
 * **Details**
 *
 * If any fiber fails, the returned `Effect` fails with that fiber's cause and
 * stops waiting for additional results. This does not interrupt the remaining
 * fibers.
 *
 * **Gotchas**
 *
 * A failure stops waiting, but it does not interrupt any other fibers. Use
 * {@link interruptAll} separately when remaining fibers should be stopped.
 *
 * @see {@link awaitAll} for collecting every fiber outcome as an Exit
 *
 * @category combinators
 * @since 2.0.0
 */
export const joinAll: <A extends Iterable<Fiber<any, any>>>(
  self: A
) => Effect<
  Arr.ReadonlyArray.With<
    A,
    A extends Iterable<Fiber<infer _A, infer _E>> ? _A : never
  >,
  A extends Fiber<infer _A, infer _E> ? _E : never
> = effect.fiberJoinAll

/**
 * Interrupts a fiber, causing it to stop executing and clean up any
 * acquired resources.
 *
 * **When to use**
 *
 * Use when a forked fiber is no longer needed and should be cancelled.
 *
 * **Details**
 *
 * The returned Effect completes only after the interrupted fiber has completed.
 *
 * **Gotchas**
 *
 * Interruption is cooperative. A fiber can continue running while it is inside
 * uninterruptible work or finalizers.
 *
 * **Example** (Interrupting a fiber)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   const fiber = yield* Effect.forkChild(
 *     Effect.delay("1 second")(Effect.succeed(42))
 *   )
 *   yield* Fiber.interrupt(fiber)
 *   console.log("Fiber interrupted")
 * })
 * ```
 *
 * @see {@link interruptAs} for specifying the interrupting fiber ID
 * @see {@link await_ await} for observing the interrupted fiber's Exit
 *
 * @category interruption
 * @since 2.0.0
 */
export const interrupt: <A, E>(self: Fiber<A, E>) => Effect<void> = effect.fiberInterrupt

/**
 * Interrupts a fiber with a specific fiber ID as the interruptor. This allows
 * tracking which fiber initiated the interruption.
 *
 * **When to use**
 *
 * Use when runtime diagnostics or tracing should attribute the interruption to
 * a specific fiber ID.
 *
 * **Details**
 *
 * The returned Effect completes only after the interrupted fiber has completed.
 *
 * **Gotchas**
 *
 * The supplied ID affects the recorded interruptor. It does not make
 * interruption synchronous or force uninterruptible regions to stop early.
 *
 * **Example** (Interrupting a fiber as another fiber)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   const targetFiber = yield* Effect.forkChild(
 *     Effect.delay("5 seconds")(Effect.succeed("task completed"))
 *   )
 *
 *   // Interrupt the fiber, specifying fiber ID 123 as the interruptor
 *   yield* Fiber.interruptAs(targetFiber, 123)
 *   console.log("Fiber interrupted by fiber #123")
 * })
 * ```
 *
 * @see {@link interrupt} for using the current fiber as the interruptor
 *
 * @category interruption
 * @since 2.0.0
 */
export const interruptAs: {
  /**
   * Interrupts a fiber with a specific fiber ID as the interruptor. This allows
   * tracking which fiber initiated the interruption.
   *
   * **When to use**
   *
   * Use when runtime diagnostics or tracing should attribute the interruption to
   * a specific fiber ID.
   *
   * **Details**
   *
   * The returned Effect completes only after the interrupted fiber has completed.
   *
   * **Gotchas**
   *
   * The supplied ID affects the recorded interruptor. It does not make
   * interruption synchronous or force uninterruptible regions to stop early.
   *
   * **Example** (Interrupting a fiber as another fiber)
   *
   * ```ts
   * import { Effect, Fiber } from "effect"
   *
   * const program = Effect.gen(function*() {
   *   const targetFiber = yield* Effect.forkChild(
   *     Effect.delay("5 seconds")(Effect.succeed("task completed"))
   *   )
   *
   *   // Interrupt the fiber, specifying fiber ID 123 as the interruptor
   *   yield* Fiber.interruptAs(targetFiber, 123)
   *   console.log("Fiber interrupted by fiber #123")
   * })
   * ```
   *
   * @see {@link interrupt} for using the current fiber as the interruptor
   *
   * @category interruption
   * @since 2.0.0
   */
  (
    fiberId: number | undefined,
    annotations?: Context.Context<never> | undefined
  ): <A, E>(self: Fiber<A, E>) => Effect<void>
  /**
   * Interrupts a fiber with a specific fiber ID as the interruptor. This allows
   * tracking which fiber initiated the interruption.
   *
   * **When to use**
   *
   * Use when runtime diagnostics or tracing should attribute the interruption to
   * a specific fiber ID.
   *
   * **Details**
   *
   * The returned Effect completes only after the interrupted fiber has completed.
   *
   * **Gotchas**
   *
   * The supplied ID affects the recorded interruptor. It does not make
   * interruption synchronous or force uninterruptible regions to stop early.
   *
   * **Example** (Interrupting a fiber as another fiber)
   *
   * ```ts
   * import { Effect, Fiber } from "effect"
   *
   * const program = Effect.gen(function*() {
   *   const targetFiber = yield* Effect.forkChild(
   *     Effect.delay("5 seconds")(Effect.succeed("task completed"))
   *   )
   *
   *   // Interrupt the fiber, specifying fiber ID 123 as the interruptor
   *   yield* Fiber.interruptAs(targetFiber, 123)
   *   console.log("Fiber interrupted by fiber #123")
   * })
   * ```
   *
   * @see {@link interrupt} for using the current fiber as the interruptor
   *
   * @category interruption
   * @since 2.0.0
   */
  <A, E>(
    self: Fiber<A, E>,
    fiberId: number | undefined,
    annotations?: Context.Context<never> | undefined
  ): Effect<void>
} = effect.fiberInterruptAs

/**
 * Interrupts all fibers in the provided iterable, causing them to stop executing
 * and clean up any acquired resources.
 *
 * **When to use**
 *
 * Use when a group of forked fibers is no longer needed.
 *
 * **Details**
 *
 * The current fiber is recorded as the interruptor. The returned Effect
 * completes only after all interrupted fibers have completed.
 *
 * **Gotchas**
 *
 * Interruption is cooperative for each fiber. The returned Effect can wait for
 * uninterruptible work and finalizers in any interrupted fiber.
 *
 * **Example** (Interrupting multiple fibers)
 *
 * ```ts
 * import { Console, Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   // Create multiple long-running fibers
 *   const fiber1 = yield* Effect.forkChild(
 *     Effect.gen(function*() {
 *       yield* Effect.sleep("5 seconds")
 *       yield* Console.log("Task 1 completed")
 *       return "result1"
 *     })
 *   )
 *
 *   const fiber2 = yield* Effect.forkChild(
 *     Effect.gen(function*() {
 *       yield* Effect.sleep("3 seconds")
 *       yield* Console.log("Task 2 completed")
 *       return "result2"
 *     })
 *   )
 *
 *   const fiber3 = yield* Effect.forkChild(
 *     Effect.gen(function*() {
 *       yield* Effect.sleep("4 seconds")
 *       yield* Console.log("Task 3 completed")
 *       return "result3"
 *     })
 *   )
 *
 *   // Wait a bit, then interrupt all fibers
 *   yield* Effect.sleep("1 second")
 *   yield* Console.log("Interrupting all fibers...")
 *   yield* Fiber.interruptAll([fiber1, fiber2, fiber3])
 *   yield* Console.log("All fibers have been interrupted")
 * })
 * ```
 *
 * @see {@link interruptAllAs} for specifying the interrupting fiber ID
 *
 * @category interruption
 * @since 2.0.0
 */
export const interruptAll: <A extends Iterable<Fiber<any, any>>>(
  fibers: A
) => Effect<void> = effect.fiberInterruptAll

/**
 * Interrupts all fibers in the provided iterable using the specified fiber ID as the
 * interrupting fiber. This allows you to control which fiber is considered the source
 * of the interruption, which can be useful for debugging and tracing.
 *
 * **When to use**
 *
 * Use to interrupt several fibers while recording a specific fiber ID as the
 * interruptor.
 *
 * **Details**
 *
 * The returned Effect completes only after all interrupted fibers have
 * completed.
 *
 * **Gotchas**
 *
 * The supplied ID affects the recorded interruptor. It does not make
 * interruption synchronous or force uninterruptible regions to stop early.
 *
 * **Example** (Interrupting multiple fibers as another fiber)
 *
 * ```ts
 * import { Console, Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   // Create a controlling fiber
 *   const controllerFiber = yield* Effect.forkChild(Effect.succeed("controller"))
 *
 *   // Create multiple worker fibers
 *   const worker1 = yield* Effect.forkChild(
 *     Effect.gen(function*() {
 *       yield* Effect.sleep("5 seconds")
 *       yield* Console.log("Worker 1 completed")
 *       return "worker1"
 *     })
 *   )
 *
 *   const worker2 = yield* Effect.forkChild(
 *     Effect.gen(function*() {
 *       yield* Effect.sleep("3 seconds")
 *       yield* Console.log("Worker 2 completed")
 *       return "worker2"
 *     })
 *   )
 *
 *   // Interrupt all workers using the controller fiber's ID
 *   yield* Effect.sleep("1 second")
 *   yield* Console.log("Interrupting workers from controller...")
 *   yield* Fiber.interruptAllAs([worker1, worker2], controllerFiber.id)
 *   yield* Console.log("All workers interrupted by controller")
 * })
 * ```
 *
 * @see {@link interruptAll} for using the current fiber as the interruptor
 *
 * @category interruption
 * @since 2.0.0
 */
export const interruptAllAs: {
  /**
   * Interrupts all fibers in the provided iterable using the specified fiber ID as the
   * interrupting fiber. This allows you to control which fiber is considered the source
   * of the interruption, which can be useful for debugging and tracing.
   *
   * **When to use**
   *
   * Use to interrupt several fibers while recording a specific fiber ID as the
   * interruptor.
   *
   * **Details**
   *
   * The returned Effect completes only after all interrupted fibers have
   * completed.
   *
   * **Gotchas**
   *
   * The supplied ID affects the recorded interruptor. It does not make
   * interruption synchronous or force uninterruptible regions to stop early.
   *
   * **Example** (Interrupting multiple fibers as another fiber)
   *
   * ```ts
   * import { Console, Effect, Fiber } from "effect"
   *
   * const program = Effect.gen(function*() {
   *   // Create a controlling fiber
   *   const controllerFiber = yield* Effect.forkChild(Effect.succeed("controller"))
   *
   *   // Create multiple worker fibers
   *   const worker1 = yield* Effect.forkChild(
   *     Effect.gen(function*() {
   *       yield* Effect.sleep("5 seconds")
   *       yield* Console.log("Worker 1 completed")
   *       return "worker1"
   *     })
   *   )
   *
   *   const worker2 = yield* Effect.forkChild(
   *     Effect.gen(function*() {
   *       yield* Effect.sleep("3 seconds")
   *       yield* Console.log("Worker 2 completed")
   *       return "worker2"
   *     })
   *   )
   *
   *   // Interrupt all workers using the controller fiber's ID
   *   yield* Effect.sleep("1 second")
   *   yield* Console.log("Interrupting workers from controller...")
   *   yield* Fiber.interruptAllAs([worker1, worker2], controllerFiber.id)
   *   yield* Console.log("All workers interrupted by controller")
   * })
   * ```
   *
   * @see {@link interruptAll} for using the current fiber as the interruptor
   *
   * @category interruption
   * @since 2.0.0
   */
  (fiberId: number): <A extends Iterable<Fiber<any, any>>>(fibers: A) => Effect<void>
  /**
   * Interrupts all fibers in the provided iterable using the specified fiber ID as the
   * interrupting fiber. This allows you to control which fiber is considered the source
   * of the interruption, which can be useful for debugging and tracing.
   *
   * **When to use**
   *
   * Use to interrupt several fibers while recording a specific fiber ID as the
   * interruptor.
   *
   * **Details**
   *
   * The returned Effect completes only after all interrupted fibers have
   * completed.
   *
   * **Gotchas**
   *
   * The supplied ID affects the recorded interruptor. It does not make
   * interruption synchronous or force uninterruptible regions to stop early.
   *
   * **Example** (Interrupting multiple fibers as another fiber)
   *
   * ```ts
   * import { Console, Effect, Fiber } from "effect"
   *
   * const program = Effect.gen(function*() {
   *   // Create a controlling fiber
   *   const controllerFiber = yield* Effect.forkChild(Effect.succeed("controller"))
   *
   *   // Create multiple worker fibers
   *   const worker1 = yield* Effect.forkChild(
   *     Effect.gen(function*() {
   *       yield* Effect.sleep("5 seconds")
   *       yield* Console.log("Worker 1 completed")
   *       return "worker1"
   *     })
   *   )
   *
   *   const worker2 = yield* Effect.forkChild(
   *     Effect.gen(function*() {
   *       yield* Effect.sleep("3 seconds")
   *       yield* Console.log("Worker 2 completed")
   *       return "worker2"
   *     })
   *   )
   *
   *   // Interrupt all workers using the controller fiber's ID
   *   yield* Effect.sleep("1 second")
   *   yield* Console.log("Interrupting workers from controller...")
   *   yield* Fiber.interruptAllAs([worker1, worker2], controllerFiber.id)
   *   yield* Console.log("All workers interrupted by controller")
   * })
   * ```
   *
   * @see {@link interruptAll} for using the current fiber as the interruptor
   *
   * @category interruption
   * @since 2.0.0
   */
  <A extends Iterable<Fiber<any, any>>>(fibers: A, fiberId: number): Effect<void>
} = effect.fiberInterruptAllAs

/**
 * Checks whether a value is a Fiber. This is a type guard that can be used to
 * determine if an unknown value is a Fiber instance.
 *
 * **When to use**
 *
 * Use when checking values at boundaries where an unknown value may be a
 * runtime fiber.
 *
 * **Details**
 *
 * The check looks for the internal Fiber type ID marker and does not inspect
 * the fiber's current state.
 *
 * **Example** (Checking for fibers)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   // Create a fiber
 *   const fiber = yield* Effect.forkChild(Effect.succeed(42))
 *
 *   // Test if values are fibers
 *   console.log(Fiber.isFiber(fiber)) // true
 *   console.log(Fiber.isFiber("hello")) // false
 *   console.log(Fiber.isFiber(42)) // false
 *   console.log(Fiber.isFiber(null)) // false
 *
 *   // Use as a type guard
 *   const maybeValue: unknown = fiber
 *   if (Fiber.isFiber(maybeValue)) {
 *     // TypeScript knows maybeValue is a Fiber here
 *     console.log(`Fiber ID: ${maybeValue.id}`)
 *   }
 * })
 * ```
 *
 * @category guards
 * @since 2.0.0
 */
export const isFiber = (
  u: unknown
): u is Fiber<unknown, unknown> => hasProperty(u, effect.FiberTypeId)

/**
 * Returns the current fiber if called from within a fiber context,
 * otherwise returns `undefined`.
 *
 * **When to use**
 *
 * Use when you need low-level runtime integrations that need access to the currently
 * executing fiber.
 *
 * **Gotchas**
 *
 * This is a synchronous accessor, not an Effect. It returns `undefined` outside
 * an active fiber runtime context.
 *
 * **Example** (Getting the current fiber)
 *
 * ```ts
 * import { Effect, Fiber } from "effect"
 *
 * const program = Effect.gen(function*() {
 *   const current = Fiber.getCurrent()
 *   if (current) {
 *     console.log(`Current fiber ID: ${current.id}`)
 *   }
 * })
 * ```
 *
 * @category accessors
 * @since 4.0.0
 */
export const getCurrent: () => Fiber<any, any> | undefined = effect.getCurrentFiber

/**
 * Adds a fiber to a `Scope` and returns the same fiber.
 *
 * **When to use**
 *
 * Use when a manually managed fiber should be interrupted when a Scope closes.
 *
 * **Details**
 *
 * When the scope is closed, the fiber is interrupted. If the scope is already
 * closed, the fiber is interrupted immediately.
 *
 * **Gotchas**
 *
 * This does not wait for the fiber to complete. It only registers the
 * interruption finalizer and returns the same fiber.
 *
 * @see {@link interrupt} for interrupting and waiting for completion
 *
 * @category resource management
 * @since 4.0.0
 */
export const runIn: {
  /**
   * Adds a fiber to a `Scope` and returns the same fiber.
   *
   * **When to use**
   *
   * Use when a manually managed fiber should be interrupted when a Scope closes.
   *
   * **Details**
   *
   * When the scope is closed, the fiber is interrupted. If the scope is already
   * closed, the fiber is interrupted immediately.
   *
   * **Gotchas**
   *
   * This does not wait for the fiber to complete. It only registers the
   * interruption finalizer and returns the same fiber.
   *
   * @see {@link interrupt} for interrupting and waiting for completion
   *
   * @category resource management
   * @since 4.0.0
   */
  (scope: Scope): <A, E>(self: Fiber<A, E>) => Fiber<A, E>
  /**
   * Adds a fiber to a `Scope` and returns the same fiber.
   *
   * **When to use**
   *
   * Use when a manually managed fiber should be interrupted when a Scope closes.
   *
   * **Details**
   *
   * When the scope is closed, the fiber is interrupted. If the scope is already
   * closed, the fiber is interrupted immediately.
   *
   * **Gotchas**
   *
   * This does not wait for the fiber to complete. It only registers the
   * interruption finalizer and returns the same fiber.
   *
   * @see {@link interrupt} for interrupting and waiting for completion
   *
   * @category resource management
   * @since 4.0.0
   */
  <A, E>(self: Fiber<A, E>, scope: Scope): Fiber<A, E>
} = effect.fiberRunIn