pubsubtest

Documentation

Index

• Variables
• type AsyncResults
  • 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

Variables

var Eventually = assert.Eventually{
	RetryStrategy: &Waiter,
}

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

Types

type AsyncResults

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

func Subscribe

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

func (*AsyncResults[Data]) Add

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

func (*AsyncResults[Data]) Eventually

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

func (*AsyncResults[Data]) Finish

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

func (*AsyncResults[Data]) ReceivedAt

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

func (*AsyncResults[Data]) Subscription

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

func (*AsyncResults[Data]) Values

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