{"version":3,"sources":["../../src/streaming/transports.ts"],"sourcesContent":["import { IOStreamTransport } from './types';\r\n\r\n/** Node.js HTTP transport (ServerResponse-like). */\r\nexport function nodeHttpTransport(res: { write: (chunk: any) => any; flush?: () => void }): IOStreamTransport {\r\n  return {\r\n    send(chunk) {\r\n      res.write(chunk);\r\n      if (typeof res.flush === 'function') res.flush();\r\n    }\r\n  };\r\n}\r\n\r\n/** WebSocket transport (ws or browser ws-like). */\r\nexport function webSocketTransport(ws: { send: (data: any) => any }): IOStreamTransport {\r\n  return {\r\n    send(chunk) {\r\n      ws.send(chunk);\r\n    }\r\n  };\r\n}\r\n"],"mappings":";;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAGO,SAAS,kBAAkB,KAA4E;AAC5G,SAAO;AAAA,IACL,KAAK,OAAO;AACV,UAAI,MAAM,KAAK;AACf,UAAI,OAAO,IAAI,UAAU,WAAY,KAAI,MAAM;AAAA,IACjD;AAAA,EACF;AACF;AAGO,SAAS,mBAAmB,IAAqD;AACtF,SAAO;AAAA,IACL,KAAK,OAAO;AACV,SAAG,KAAK,KAAK;AAAA,IACf;AAAA,EACF;AACF;","names":[]}