Question(farrow-http): how to work with react 18 renderToPipeableStream

[tqma113]

https://codesandbox.io/s/kind-sammet-j56ro?file=/server/render.js:1217-1223
reactwg/react-18#22

const { pipe, abort } = renderToPipeableStream(
    <DataProvider data={data}>
      <App assets={assets} />
    </DataProvider>,
    {
      bootstrapScripts: [assets["main.js"]],
      onCompleteShell() {
        res.statusCode = didError ? 500 : 200;
        res.setHeader("Content-type", "text/html");
        pipe(res); // Here is the conflict point
      },
      onError(x) {
        didError = true;
        console.error(x);
      }
    }
  );

How to do pipe(res) with farrow-http?

[Lucifier129]

Response.custom(handler) is for this use-case.

const renderReactStream = (elem, options) => {
  return Response.custom(( { res } ) => {
    const { pipe, abort } = renderToPipeableStream(elem,
    {
      ...options,
      onCompleteShell() {
        options?.onCompleteShell(res)
        pipe(res); // No problem!
      }
    }
  );
  })
}


http.use(request => {
  return renderReactStream( 
    <DataProvider data={data}>
      <App assets={assets} />
    </DataProvider>,
    {
      bootstrapScripts: [assets["main.js"]],
      onCompleteShell(res) {
        res.statusCode = didError ? 500 : 200;
        res.setHeader("Content-type", "text/html");
      },
      onError(x) {
        didError = true;
        console.error(x);
      }
    })
})