import { EphemeralTransport } from '../src/transports/ephemeral-transport.js';
import { TransportComposite } from '../src/transports/transport-composite.js';

import { TransportSSE } from '../src/transports/transport-sse.js';

const composite = async (url: string) =>
  TransportComposite.from(
    await Promise.all([TransportSSE.from(url), TransportSSE.from(url)]),
  );

const ephemeral = EphemeralTransport.from(composite);

const message = await ephemeral.receive(
  'https://oracles.generalprotocols.com/sse/v1/messages',
);

console.log(message);