feedback

Author: marvinhagemeister

packages/fresh/src/context.ts

@@ -27,7 +27,8 @@ import {
   renderRouteComponent,
 } from "./render.ts";
 import { renderToString } from "preact-render-to-string";
-import { isAsyncIterable, isIterable, isThenable } from "./utils.ts";
+
+const ENCODER = new TextEncoder();
 
 export interface Island {
   file: string;
@@ -472,68 +473,3 @@ function getHeadersFromInit(init?: ResponseInit) {
     ? init.headers instanceof Headers ? init.headers : new Headers(init.headers)
     : new Headers();
 }
-
-export type StreamFn<T> = (
-  controller: ReadableStreamDefaultController<T>,
-  signal: AbortSignal,
-) =>
-  | void
-  | Iterable<T, void, unknown>
-  | Promise<void>
-  | AsyncIterable<T, void, unknown>;
-
-type ChunkEncodeFn<T> = (
-  controller: ReadableStreamDefaultController<Uint8Array<ArrayBuffer>>,
-  chunk: T | undefined,
-) => void;
-
-function runStreamFn<T>(
-  fn: StreamFn<T>,
-  signal: AbortSignal,
-): ReadableStream<Uint8Array<ArrayBuffer>> {
-  return new ReadableStream<Uint8Array<ArrayBuffer>>({
-    async start(controller) {
-      const wrapped = wrapStreamController(
-        controller,
-        enqueueEncodedChunk,
-      );
-      await fn(wrapped, signal);
-      controller.close();
-    },
-  });
-}
-
-function wrapStreamController<T>(
-  controller: ReadableStreamDefaultController<Uint8Array<ArrayBuffer>>,
-  encode: ChunkEncodeFn<T>,
-): ReadableStreamDefaultController<T> {
-  return {
-    get desiredSize() {
-      return controller.desiredSize;
-    },
-    close: () => controller.close,
-    enqueue(chunk) {
-      encode(controller, chunk);
-    },
-    error: (err) => controller.error(err),
-  };
-}
-
-const ENCODER = new TextEncoder();
-
-function enqueueEncodedChunk<T>(
-  controller: ReadableStreamDefaultController<Uint8Array<ArrayBuffer>>,
-  chunk: T | undefined,
-) {
-  if (chunk === undefined) {
-    return controller.enqueue(undefined);
-  }
-
-  if (chunk instanceof Uint8Array) {
-    // deno-lint-ignore no-explicit-any
-    controller.enqueue(chunk as any);
-  } else {
-    const raw = ENCODER.encode(String(chunk));
-    controller.enqueue(raw);
-  }
-}

packages/fresh/src/mod.ts

@@ -15,7 +15,7 @@ export { csrf, type CsrfOptions } from "./middlewares/csrf.ts";
 export { cors, type CORSOptions } from "./middlewares/cors.ts";
 export { csp, type CSPOptions } from "./middlewares/csp.ts";
 export type { FreshConfig, ResolvedFreshConfig } from "./config.ts";
-export type { Context, FreshContext, Island, StreamFn } from "./context.ts";
+export type { Context, FreshContext, Island } from "./context.ts";
 export { createDefine, type Define } from "./define.ts";
 export type { Method } from "./router.ts";
 export { HttpError } from "./error.ts";

packages/fresh/src/utils.ts

@@ -283,22 +283,3 @@ function maybeDot(spec: string): string {
 export function isLazy<T>(value: MaybeLazy<T>): value is Lazy<T> {
   return typeof value === "function";
 }
-
-export function isThenable(value: unknown): value is Promise<unknown> {
-  return value !== null && typeof value === "object" && "then" in value &&
-    typeof value.then === "function";
-}
-
-export function isIterable<T>(value: unknown): value is Iterable<T> {
-  return value !== null && typeof value === "object" &&
-    Symbol.iterator in value &&
-    typeof value[Symbol.iterator] === "function";
-}
-
-export function isAsyncIterable<T>(
-  value: unknown,
-): value is AsyncIterable<T> {
-  return value !== null && typeof value === "object" &&
-    Symbol.asyncIterator in value &&
-    typeof value[Symbol.asyncIterator] === "function";
-}