Method OnStartWithStreamInputFn

callbacks/handler_builder.go:141–146

OnStartWithStreamInputFn sets the callback invoked when a component receives streaming input. The handler receives a [*schema.StreamReader] that is a private copy; it MUST close the reader after consuming it to avoid goroutine and memory leaks.

(
	fn func(ctx context.Context, info *RunInfo, input *schema.StreamReader[CallbackInput]) context.Context)

// private copy; it MUST close the reader after consuming it to avoid goroutine
// and memory leaks.
func (hb *HandlerBuilder) OnStartWithStreamInputFn(
	fn func(ctx context.Context, info *RunInfo, input *schema.StreamReader[CallbackInput]) context.Context) *HandlerBuilder {

	hb.onStartWithStreamInputFn = fn
	return hb
}

// OnEndWithStreamOutputFn sets the callback invoked when a component produces
// streaming output. Like OnStartWithStreamInputFn, the handler receives a