chain.ts

import { chain } from "stream-chain"
import { parser } from "stream-json"
import { streamArray } from "stream-json/streamers/StreamArray"
import { MirakurunAPI } from "../infra/mirakurun"

const main = async () => {
  const client = new MirakurunAPI({
    baseUrl: "http://192.168.0.10:40772/api",
  })
  const claimStream = await client.events.getEventsStream(
    "program",
    undefined,
    {
      responseType: "stream",
    }
  )
  const pipeline = chain([claimStream.data as any, parser(), streamArray()])
  pipeline.on("data", () => (claimStream.data as any).destroy())
  pipeline.destroy()
}
main()