Streaming on next

logs.ts

import { getSession } from 'next-auth/client';
import { NextApiRequest, NextApiResponse } from 'next';

export default async (req: NextApiRequest, res: NextApiResponse) => {
  const { pod, container, env } = req.query;
  const session = await getSession({ req });
  if (!session) {
    return res.status(403).end('Forbidden');
  }
  res.writeHead(200, {
    'Content-Type': 'text/plain; charset=utf-8',
    'Transfer-Encoding': 'chunked',
  });
  res.flushHeaders();
  const logResponse = await getLogs(
    env as string,
    pod as string,
    container as string,
  );
  for await (const chunk of logResponse.body) {
    res.write(chunk);
    await (res as any).flush();
  }
};