streamtest

type In struct {
	// Application is a test application that is configured to record the events
	// used within the test suite.
	Application configkit.RichApplication

	// EventTypes is the set of event types that the test application produces.
	EventTypes *sets.Set[message.Type]

	// Marshaler marshals and unmarshals the test message types.
	Marshaler marshaler.Marshaler
}

type Out struct {
	// Stream is the stream under test.
	Stream eventstream.Stream

	// TestTimeout is the maximum duration allowed for each test.
	TestTimeout time.Duration

	// AssumeBlockingDuration specifies how long the tests should wait before
	// assuming a call to Cursor.Next() is successfully blocking, waiting for a
	// new message, as opposed to in the process of "checking" if any messages
	// are already available.
	AssumeBlockingDuration time.Duration

	// Append is a function that appends messages to the stream.
	Append func(context.Context, ...parcel.Parcel)
}