Revert "Improve uint8array serializing perf"

src/actors/runtime.ts

@@ -11,7 +11,6 @@ import type { ActorStorage } from "./storage.ts";
 import { DenoKvActorStorage } from "./storage/denoKv.ts";
 import { S3ActorStorage } from "./storage/s3.ts";
 import { EVENT_STREAM_RESPONSE_HEADER } from "./stream.ts";
-import { serializeUint8Array } from "./util/buffers.ts";
 import { isUpgrade, makeWebSocket } from "./util/channels/channel.ts";
 import {
   type ServerSentEventMessage,
@@ -191,7 +190,7 @@ export class ActorRuntime {
               for await (const content of res) {
                 controller.enqueue({
                   data: encodeURIComponent(
-                    JSON.stringify(content, serializeUint8Array),
+                    JSON.stringify(content),
                   ),
                   id: Date.now().toString(),
                   event: "message",

src/actors/stream.ts

@@ -1,5 +1,3 @@
-import { deserializeUint8Array } from "./util/buffers.ts";
-
 export const EVENT_STREAM_RESPONSE_HEADER: string = "text/event-stream";
 export async function* readFromStream<T>(
   response: Response,
@@ -30,7 +28,7 @@ export async function* readFromStream<T>(
 
       try {
         const chunk = data.replace("data:", "");
-        yield JSON.parse(decodeURIComponent(chunk), deserializeUint8Array);
+        yield JSON.parse(decodeURIComponent(chunk));
       } catch (_err) {
         console.log("error parsing data", _err, data);
         continue;
@@ -43,7 +41,6 @@ export async function* readFromStream<T>(
     try {
       yield JSON.parse(
         decodeURIComponent(buffer.replace("data:", "")),
-        deserializeUint8Array,
       );
     } catch (_err) {
       console.log("error parsing data", _err, buffer);