reactor

Nov 22, 2020

Changes in this version

+ func NewContextError(err error) error

Nov 15, 2020

Changes in this version

+ type Item struct

+ E error

+ V Any

Oct 8, 2020

Changes in this version

+ var CoreCounts int32

Sep 21, 2020

Changes in this version

+ func IsCancelledError(err error) bool

Aug 4, 2020

Changes in this version

+ type Any = interface

Jul 17, 2019

Changes in this version

+ type SignalType int8

+ const SignalTypeCancel

+ const SignalTypeComplete

+ const SignalTypeDefault

+ const SignalTypeError

+ func (s SignalType) String() string

Jul 11, 2019

Changes in this version

+ var ErrNegativeRequest = fmt.Errorf("invalid request: n must be between %d and %d", 1, RequestInfinite)

+ var ErrSubscribeCancelled = errors.New("subscriber has been cancelled")

+ type FnOnDiscard = func(interface{})

Jul 7, 2019

Changes in this version

+ var ErrCancelled = errors.New("subscriber has been cancelled")

+ type RawPublisher interface

+ SubscribeWith func(context.Context, Subscriber)

Jul 3, 2019

Changes in this version

+ const RequestInfinite

+ type Disposable interface

+ Dispose func()

+ IsDisposed func() bool

+ type FnOnCancel = func()

+ type FnOnComplete = func()

+ type FnOnError = func(error)

+ type FnOnFinally = func(Signal)

+ type FnOnNext = func(s Subscription, v interface{})

+ type FnOnRequest = func(int)

+ type FnOnSubscribe = func(Subscription)

+ type Predicate func(interface{}) bool

+ type Processor interface

+ type Publisher interface

+ Subscribe func(context.Context, Subscriber)

+ type Signal int8

+ const SignalCancel

+ const SignalComplete

+ const SignalDefault

+ const SignalError

+ func (s Signal) String() string

+ type Subscriber interface

+ OnComplete func()

+ OnError func(error)

+ OnNext func(Subscription, interface{})

+ OnSubscribe func(Subscription)

+ func NewSubscriber(opts ...SubscriberOption) Subscriber

+ type SubscriberOption func(*subscriber)

+ func OnComplete(onComplete FnOnComplete) SubscriberOption

+ func OnError(onError FnOnError) SubscriberOption

+ func OnNext(onNext FnOnNext) SubscriberOption

+ func OnSubscribe(onSubscribe FnOnSubscribe) SubscriberOption

+ type Subscription interface

+ Cancel func()

+ Request func(n int)

+ type Transformer func(interface{}) interface