ibrahimyaacob Posts - Answer Overflow

import { type NextApiRequest, type NextApiResponse } from "next";
import stream from "stream";

export default function Handler(req: NextApiRequest, res: NextApiResponse) {
  // Set the response headers to indicate it's a text stream
  res.setHeader("Content-Type", "text/event-stream");

  // Create a readable stream from your string
  const wordsToStream =
    "This is the string you want to s as daslfalfj kldfklsad nhkgl skgskdg njkhdgnkjdnj njknjksjgnsjd gsdng ds sndgk dskl stream\n";

  const words = wordsToStream.split(" ");
  let currentIndex = 0;

  const readableStream = new stream.Readable({
    read(size) {
      if (currentIndex < words.length) {
        this.push(words[currentIndex] + " "); // Push a word with a space
        currentIndex++;
        setTimeout(() => {
          this._read();
        }, 1000); // Delay for 500 milliseconds
      } else {
        this.push(null); // Signal the end of the stream
      }
    },
  });

  // Pipe the readable stream to the response
  readableStream.pipe(res);
}

import { type NextApiRequest, type NextApiResponse } from "next";
import stream from "stream";

export default function Handler(req: NextApiRequest, res: NextApiResponse) {
  // Set the response headers to indicate it's a text stream
  res.setHeader("Content-Type", "text/event-stream");

  // Create a readable stream from your string
  const wordsToStream =
    "This is the string you want to s as daslfalfj kldfklsad nhkgl skgskdg njkhdgnkjdnj njknjksjgnsjd gsdng ds sndgk dskl stream\n";

  const words = wordsToStream.split(" ");
  let currentIndex = 0;

  const readableStream = new stream.Readable({
    read(size) {
      if (currentIndex < words.length) {
        this.push(words[currentIndex] + " "); // Push a word with a space
        currentIndex++;
        setTimeout(() => {
          this._read();
        }, 1000); // Delay for 500 milliseconds
      } else {
        this.push(null); // Signal the end of the stream
      }
    },
  });

  // Pipe the readable stream to the response
  readableStream.pipe(res);
}

2 replies

TTCTheo's Typesafe Cult

•Created by ibrahimyaacob on 10/19/2023 in #questions

with trpc, how to invalidate query only when there's the query cached exist?

it seems like utils.myRouter.myQuery.invalidate(), triggers the query, even though api.myRouter.myQuery.useQuery() is not called from the page. how do i prevent this

3 replies

TtRPC

•Created by ibrahimyaacob on 10/19/2023 in #❓-help

does api.myQuery.invalidate() works if the query is not made at the first place?

from testing, the invalidate runs the query, but it shouldn't because there is no cache? how do i invalidate ONLY when the cache exist ?

3 replies

TTCTheo's Typesafe Cult

•Created by ibrahimyaacob on 10/16/2023 in #questions

npx create/npm create just freeze forever