stream

Documentation

Overview

Package stream implements Server-Sent Events streaming. It is surfaced through fal.Client.Stream and the package-level fal.Stream.

Index

• func Stream(ctx context.Context, core *transport.Core, application string, arguments any, ...) iter.Seq2[map[string]any, error]

Functions

func Stream

func Stream(ctx context.Context, core *transport.Core, application string, arguments any, o *option.CallOptions) iter.Seq2[map[string]any, error]

Stream opens a Server-Sent Events stream and yields each decoded JSON event. It mirrors fal_client.stream / SyncClient.stream. The default sub-path is "/stream"; override it with WithPath. A non-nil error is yielded once and ends iteration; breaking the range early closes the connection.