Streaming from HttpApi

  streamTokenizedResponse: () => Effect.gen(function* () {
    const remoteChain = new RemoteRunnable({
      url: `https://mylangchain.com`
    });

    const remoteStream = yield* Effect.tryPromise({
      try: () =>
        remoteChain.stream(
          {
            question: "What's your favourite colour?"
          },
          {
            configurable: {
              session_id: '123abc'
            }
          }
        ),
      catch: (error) =>
        new Error(`Failed to establish a streaming connection: ${error}`)
    });

    return Stream.fromAsyncIterable(
      remoteStream, // Pass the async iterable
      (error) => Effect.fail(new Error('Streaming failed'))
    ) as Stream.Stream<string>;
  })

export const MyApi = HttpApi.make('MyApi').add(
  HttpApiGroup.make('chat')
    .add(
      HttpApiEndpoint.get('ask')`/chat`
        .addSuccess(Schema.Array(Schema.String))
    )
);

export const MyChatLive = HttpApiBuilder.group(MyApi, 'chat', (handlers) =>
  Effect.gen(function* () {
    const searchService = yield* SearchService;

    return handlers.handle(
      'ask',
      () =>
        Effect.succeed(
          searchService.streamTokenizedResponse() as Stream.Stream<string>
        )
    );
  })
);