pubsubtest

package

v0.238.0 Latest Latest Go to latest Published: Sep 10, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var Eventually = assert.Retry{
	Strategy: &Waiter,
}

View Source

var Waiter = assert.Waiter{
	WaitDuration: time.Millisecond,
	Timeout:      5 * time.Second,
}

This section is empty.

type AsyncResults[Data any] struct {
	// contains filtered or unexported fields
}

func Subscribe[Data any](tb testing.TB, sub pubsub.Subscriber[Data], ctx context.Context) *AsyncResults[Data]

func (r *AsyncResults[Data]) Add(d Data)

func (r *AsyncResults[Data]) Eventually(tb testing.TB, blk func(testing.TB, []Data))

func (r *AsyncResults[Data]) Finish()

func (r *AsyncResults[Data]) ReceivedAt() time.Time

func (r *AsyncResults[Data]) Subscription() pubsub.Subscription[Data]

func (r *AsyncResults[Data]) Values() []Data