rxtest

Documentation

Index

• Variables
• func AddLatencyToNotifications[T any](initialDelay, period int) rx.Operator[T, T]
• func AddLatencyToValues[T any](initialDelay, period int) rx.Operator[T, T]
• func DelaySubscription[T any](n int) rx.Operator[T, T]
• func Step(n int) time.Duration
• func ToString[T any]() rx.Operator[T, string]
• type TestSuite
  • func NewTestSuite[T any](tb testing.TB) *TestSuite[T]
  • func (s *TestSuite[T]) Case(ob rx.Observable[T], output ...any) *TestSuite[T]
  • func (s *TestSuite[T]) WithContext(c rx.Context) *TestSuite[T]

Variables

var (
	ErrComplete = errors.New("complete")
	ErrTest     = errors.New("test")
)

Functions

func AddLatencyToNotifications

func AddLatencyToNotifications[T any](initialDelay, period int) rx.Operator[T, T]

func AddLatencyToValues

func AddLatencyToValues[T any](initialDelay, period int) rx.Operator[T, T]

func DelaySubscription

func DelaySubscription[T any](n int) rx.Operator[T, T]

func Step

func Step(n int) time.Duration

func ToString

func ToString[T any]() rx.Operator[T, string]

Types

type TestSuite

type TestSuite[T any] struct {
	// contains filtered or unexported fields
}

func NewTestSuite

func NewTestSuite[T any](tb testing.TB) *TestSuite[T]

func (*TestSuite[T]) Case

func (s *TestSuite[T]) Case(ob rx.Observable[T], output ...any) *TestSuite[T]

func (*TestSuite[T]) WithContext

func (s *TestSuite[T]) WithContext(c rx.Context) *TestSuite[T]