The highest tagged major version is v2.

streamconformance

package

v1.1.5 Latest Latest Go to latest Published: Oct 22, 2026 License: MIT Imports: 7 Imported by: 0

Details

Package streamconformance defines the shared behavioral contract exercised by every first-class Streams worker.

This section is empty.

This section is empty.

func Run(t *testing.T, backendName string, factory Factory)

Run exercises the stable worker behavior shared by native stream backends.

type Factory func(
	t *testing.T,
	run func(context.Context, core.TaskMessage) error,
	requestTimeout time.Duration,
) core.Worker

Factory constructs an isolated worker with the supplied handler and request timeout. Implementations must register their own resource cleanup with t.