matthewp/readme.md

## readme.md

      
    Raw
  

              readme.md
            
          
    deno run --allow-net --unstable server.js


## server.js
function createStream(iterator) {
  const encoder = new TextEncoder();
  return new ReadableStream({
    async pull(controller) {
      const { value, done } = await iterator.next();

      if (done) {
        controller.close();
      } else {
        const chunk = encoder.encode(value);
        controller.enqueue(chunk);
      }
    },
  });
}

const wait = () => new Promise(resolve => setTimeout(resolve, 2000));

async function * values() {
  yield '<html><head><title>something</title></head><h1>1</h1>';
  await wait();
  yield '<h2>2</h2>';
  await wait();
  yield '<h3>3</h3>';
  await wait();
  yield '<h4>4</h4>';
  await wait();
}

async function handle(conn) {
  const httpConn = Deno.serveHttp(conn);
  for await (const requestEvent of httpConn) {
    const stream = createStream(values());
    requestEvent.respondWith(new Response(stream, {
      status: 200,
      headers: {
        'content-type': 'text/html',
        'transfer-encoding': 'chunked'
      }
    }));
  }
}

async function listen(server) {
  for await (const conn of server) {
    handle(conn);
  }
}

export function startServer() {
  const server = Deno.listen({ port: 8080 });
  console.log(`Listening at http://localhost:${8080}`);
  listen(server);
  return server;
}

startServer();
	function createStream(iterator) {
	const encoder = new TextEncoder();
	return new ReadableStream({
	async pull(controller) {
	const { value, done } = await iterator.next();

	if (done) {
	controller.close();
	} else {
	const chunk = encoder.encode(value);
	controller.enqueue(chunk);
	}
	},
	});
	}

	const wait = () => new Promise(resolve => setTimeout(resolve, 2000));

	async function * values() {
	yield '<html><head><title>something</title></head><h1>1</h1>';
	await wait();
	yield '<h2>2</h2>';
	await wait();
	yield '<h3>3</h3>';
	await wait();
	yield '<h4>4</h4>';
	await wait();
	}

	async function handle(conn) {
	const httpConn = Deno.serveHttp(conn);
	for await (const requestEvent of httpConn) {
	const stream = createStream(values());
	requestEvent.respondWith(new Response(stream, {
	status: 200,
	headers: {
	'content-type': 'text/html',
	'transfer-encoding': 'chunked'
	}
	}));
	}
	}

	async function listen(server) {
	for await (const conn of server) {
	handle(conn);
	}
	}

	export function startServer() {
	const server = Deno.listen({ port: 8080 });
	console.log(`Listening at http://localhost:${8080}`);
	listen(server);
	return server;
	}

	startServer();