rxtest

Apr 1, 2023

retracted

Changes in this version

+ var ErrComplete = errors.New("complete")

Jun 23, 2022

retracted

Changes in this version

+ var ErrCompleted = errors.New("completed")

type TestSuite

+ func (s *TestSuite[T]) WithContext(ctx context.Context) *TestSuite[T]

Dec 31, 2020

retracted

Changes in this version

+ func Test(t testing.TB, source rx.Observable, output ...interface{})

+ type TestCase struct

+ Output []interface{}

+ Source rx.Observable

+ type TestSuite struct

+ func NewTestSuite(t *testing.T) *TestSuite

+ func (s *TestSuite) Case(source rx.Observable, output ...interface{}) *TestSuite

+ func (s *TestSuite) TestAll()

Jul 16, 2020

retracted

Changes in this version

+ var Completed = errors.New("completed")

Jun 19, 2020

retracted

Changes in this version

+ var ErrTest = errors.New("test")

+ func AddLatencyToNotifications(initialDelay, period int) rx.Operator

+ func AddLatencyToValues(initialDelay, period int) rx.Operator

+ func DelaySubscription(n int) rx.Operator

+ func Step(n int) time.Duration

+ func Subscribe(t *testing.T, obs rx.Observable, output ...interface{})

+ func SubscribeN(t *testing.T, observables []rx.Observable, outputs [][]interface{})

+ func ToString() rx.Operator