Safely type stream messages, which are actually items in a collection (…

…#1100)
stellar · Nov 13, 2024 · 94e1ce8 · 94e1ce8
1 parent 96a851e
commit 94e1ce8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/horizon/call_builder.ts b/src/horizon/call_builder.ts
@@ -102,7 +102,9 @@ export class CallBuilder<
    * @param {number} [options.reconnectTimeout] Custom stream connection timeout in ms, default is 15 seconds.
    * @returns {Function} Close function. Run to close the connection and stop listening for new events.
    */
-  public stream(options: EventSourceOptions<T> = {}): () => void {
+  public stream(options: EventSourceOptions<
+    T extends ServerApi.CollectionPage<infer U> ? U : T
+  > = {}): () => void {
     // Check if EventSource use is enabled
     if (EventSource === undefined){
       throw new Error("Streaming requires eventsource to be enabled. If you need this functionality, compile with USE_EVENTSOURCE=true.");