Function roundtrip

http/server_sent_event_parse_stream_test.ts:23–30

Helper to roundtrip through encode then decode

(
  messages: ServerSentEventMessage[],
)

/** Helper to roundtrip through encode then decode */
function roundtrip(
  messages: ServerSentEventMessage[],
): ReadableStream<ServerSentEventParsedMessage> {
  return ReadableStream
    .from(messages)
    .pipeThrough(new ServerSentEventStream())
    .pipeThrough(new ServerSentEventParseStream());
}

Deno.test("ServerSentEventParseStream parses data field", async () => {
  const result = await Array.fromAsync(parseStream([