Class ExecutionSession

Private Optional active

Private Readonly consumers

Private dirty

Private Optional disposal

Private disposed

Private Optional draining

Private failed

Private Optional initializedId

Private language

Private Readonly listeners

Private Optional Readonly onLastRelease

Private Readonly options

Private pending

Private phase

Private Optional recovery

Private Optional recoveryCancel

Private Readonly runtime

Private sequence

Private Readonly unsubscribeRuntime

Private assertCurrent

• assertCurrent(work): void

• Parameters

  • work: Work

  Returns void

Private beginRecovery

• beginRecovery(language): Promise<void>

• Parameters

  • language: KernelLanguage

  Returns Promise<void>

Private drain

• drain(): void

• Returns void

Private emit

• emit(): void

• Returns void

Private enqueue

• enqueue(consumerId, kind, language, input?): Promise<AttemptResult>

• Parameters

  • consumerId: string
  • kind: "run" | "reset" | "submit" | "connect"
  • language: KernelLanguage
  • Optional input: AttemptInput

  Returns Promise<AttemptResult>

Private executeRequired

• executeRequired(code, label, wait): Promise<void>

• Parameters

  • code: string
  • label: string
  • wait: (<T>(operation) => Promise<T>)
    • • <T>(operation): Promise<T>

      • Type Parameters

        • T

        Parameters

        • operation: (() => Promise<T>)
          • • (): Promise<T>

            • Returns Promise<T>

        Returns Promise<T>

  Returns Promise<void>

Private initialize

• initialize(identity, policy, wait): Promise<void>

• Parameters

  • identity: KernelIdentity
  • policy: LanguagePolicy
  • wait: (<T>(operation) => Promise<T>)
    • • <T>(operation): Promise<T>

      • Type Parameters

        • T

        Parameters

        • operation: (() => Promise<T>)
          • • (): Promise<T>

            • Returns Promise<T>

        Returns Promise<T>

  Returns Promise<void>

Private interrupt

• interrupt(): Promise<void>

• Returns Promise<void>

Private isCurrent

• isCurrent(work): boolean

• Parameters

  • work: Work

  Returns boolean

Private perform

• perform(work): Promise<AttemptResult>

• Parameters

  • work: Work

  Returns Promise<AttemptResult>

Private rejectPending

• rejectPending(reason, consumerId?): void

• Parameters

  • reason: Error
  • Optional consumerId: string

  Returns void

Private report

• report(error): void

• Parameters

  • error: unknown

  Returns void

Private setPhase

• setPhase(phase): void

• Parameters

  • phase: "connecting" | "idle" | "preparing" | "running" | "grading" | "cleaning" | "recovering" | "disposed"

  Returns void

Private wait

• wait<T>(work, operation): Promise<T>

• Type Parameters

  • T

  Parameters

  • work: Work
  • operation: (() => Promise<T>)
    • • (): Promise<T>

      • Returns Promise<T>

  Returns Promise<T>