© 2026 Hedgehog Software, LLC
ServerSentEventGenerator
export const runStream = <A, E>( makeEffect: (stream: ServerSentEventGenerator) => Effect.Effect< A, E, ManagedRuntime.ManagedRuntime.Context<typeof runtime> | HonoContext >, ) => async (c: Context) => { const exit = await runtime.runPromiseExit( Effect.tryPromise(async () => ServerSentEventGenerator.stream(async (stream) => { await runtime.runPromise( makeEffect(stream).pipe( HonoContext.provide(c), Effect.withSpan(c.req.url), ), ); }) ), ); if (Exit.isSuccess(exit)) { return exit.value; } else { const error = Cause.squash(exit.cause); console.error(Cause.pretty(exit.cause)); throw new Error("internal server error"); } };
runPromise
runPromiseExit