lint

src/index.ts

@@ -12,10 +12,10 @@
 7. Support parallel execution of steps (either dynamic via something liek a collector, or static via a few explicitly defined siblings)
  */
 
-import { jsx, jsxs, Fragment } from "./jsx-runtime";
 import { Component, StreamComponent } from "./component";
-import { Stream } from "./stream";
+import { Fragment, jsx, jsxs } from "./jsx-runtime";
 import { execute } from "./resolve";
+import { Stream } from "./stream";
 import { Element, ExecutableValue, Streamable } from "./types";
 
 // Collect component props

src/jsx-runtime.ts

@@ -1,9 +1,9 @@
 /* eslint-disable @typescript-eslint/no-namespace */
 import type { Streamable } from "./types";
 
+import { getCurrentContext } from "./context";
 import { resolveDeep } from "./resolve";
 import { isInStreamingContext } from "./stream";
-import { getCurrentContext } from "./context";
 
 export namespace JSX {
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
@@ -61,8 +61,6 @@ export const jsx = <
 
   // Return a promise that will be handled by execute()
   return (async (): Promise<Awaited<TOutput> | Awaited<TOutput>[]> => {
-    const parentContext = getCurrentContext();
-
     // Execute component
     const rawResult = await component(props ?? ({} as TProps));
     const currentContext = getCurrentContext();
@@ -111,7 +109,7 @@ export const jsx = <
         return result as Awaited<TOutput>;
       }
       // Outside streaming context, resolve the value
-      return (await result.value) as Awaited<TOutput>;
+      return await result.value;
     }
 
     // If there are no function children, return the resolved result

src/parallel.ts

@@ -1,6 +1,7 @@
 import type { Element } from "./types";
-import { execute } from "./resolve";
+
 import { getCurrentContext } from "./context";
+import { execute } from "./resolve";
 
 export async function Parallel<T>(props: {
   children: Element[] | Element;

src/resolve.ts

@@ -6,9 +6,9 @@ import type {
   WorkflowComponent,
 } from "./types";
 
+import { ExecutionContext, getCurrentContext } from "./context";
 import { JSX } from "./jsx-runtime";
 import { isInStreamingContext } from "./stream";
-import { ExecutionContext, getCurrentContext } from "./context";
 
 type ComponentType<P, O> = WorkflowComponent<P, O> | StreamComponent<P, O>;
 
@@ -53,6 +53,7 @@ export async function resolveDeep<T>(value: unknown): Promise<T> {
 
   // Handle promises first
   if (value instanceof Promise) {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     const resolved = await value;
     return resolveDeep(resolved);
   }
@@ -123,12 +124,13 @@ export async function execute<T>(
   element: ExecutableValue,
   context?: ExecutionContext,
 ): Promise<T> {
+  // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
   if (element === null || element === undefined) {
     throw new Error("Cannot execute null or undefined element");
   }
 
   // Use provided context or current context
-  const executionContext = context || getCurrentContext();
+  const executionContext = context ?? getCurrentContext();
   const wasInStreamingContext = isInStreamingContext();
 
   try {

src/stream.ts

@@ -1,7 +1,7 @@
 import type { Element, Streamable, StreamComponent } from "./types";
 
-import { execute } from "./resolve";
 import { getCurrentContext, withContext } from "./context";
+import { execute } from "./resolve";
 
 // Helper to check if a component is a stream component
 export function isStreamComponent(