fn_registry/functions/infra/wails_stream_data.md

name, kind, lang, domain, version, purity, signature, description, tags, uses_functions, uses_types, returns, returns_optional, error_type, imports, params, output, tested, tests, test_file_path, file_path

name	kind	lang	domain	version	purity	signature	description	tags	uses_functions	uses_types	returns	returns_optional	error_type	imports	params	output	tested	tests	test_file_path	file_path
wails_stream_data	function	go	infra	1.0.0	impure	WailsStreamData[T any](ctx context.Context, cfg WailsStreamConfig, data []T) error	Envía datos como stream Go→TS con protocolo {name}/{name}:complete/{name}:error. Incluye WailsStreamFunc para generadores.	wails stream ipc realtime chunks infra				false	error_go_core	context fmt time github.com/wailsapp/wails/v2/pkg/runtime	name desc ctx context de Wails name desc cfg estructura WailsStreamConfig con StreamName y ChunkDelay name desc data slice de datos genericos a enviar en chunks	nil si el stream se completo exitosamente, error en caso contrario	false			functions/infra/wails_stream_data.go

Ejemplo

// Stream de slice
WailsStreamData(ctx, WailsStreamConfig{
    StreamName: "logs",
    ChunkDelay: 10 * time.Millisecond,
}, logLines)

// Stream con generador
WailsStreamFunc(ctx, "metrics", func(ctx context.Context, ch chan<- Metric) error {
    for {
        select {
        case <-ctx.Done():
            return nil
        case <-time.After(time.Second):
            ch <- collectMetric()
        }
    }
})

// Frontend lo recibe con useWailsStream:
// useWailsStream({ streamName: 'metrics', autoStart: true })

Notas

Protocolo: chunks en {streamName}, fin en {streamName}:complete, error en {streamName}:error. Compatible con use_wails_stream del lado TS. WailsStreamFunc usa goroutine + canal para datos asíncronos. Requiere Go 1.18+ (generics) y la dependencia github.com/wailsapp/wails/v2 en el proyecto destino.