flux

Aug 4, 2020

Changes in this version

+ func InitBuffSize(size int)

+ type Any = reactor.Any

type Flux

+ BlockToSlice func(ctx context.Context, slicePtr interface{}) error

+ SubscribeWithChan func(ctx context.Context, valueChan interface{}, errChan chan<- error)

Jan 12, 2020

Changes in this version

type Flux

+ DelayElement func(delay time.Duration) Flux

Aug 5, 2019

Changes in this version

type Flux

+ BlockFirst func(context.Context) (interface{}, error)

Aug 2, 2019

Changes in this version

type Flux

+ Take func(n int) Flux

+ ToChan func(ctx context.Context, cap int) (c <-chan interface{}, e <-chan error)

Jul 22, 2019

Changes in this version

+ type CreateOption func(*fluxCreate)

+ func WithOverflowStrategy(o OverflowStrategy) CreateOption

Jul 17, 2019

Changes in this version

type Flux

+ BlockLast func(context.Context) (interface{}, error)

+ DoOnError func(rs.FnOnError) Flux

+ DoOnSubscribe func(rs.FnOnSubscribe) Flux

Jul 17, 2019

Changes in this version

+ var BuffSizeSM = 256

+ var BuffSizeXS = 32

type Flux

+ func Error(e error) Flux

+ func Range(start, count int) Flux

+ DoFinally func(rs.FnOnFinally) Flux

+ DoOnCancel func(rs.FnOnCancel) Flux

+ DoOnComplete func(rs.FnOnComplete) Flux

+ DoOnDiscard func(rs.FnOnDiscard) Flux

+ DoOnNext func(rs.FnOnNext) Flux

+ DoOnRequest func(rs.FnOnRequest) Flux

+ SwitchOnFirst func(FnSwitchOnFirst) Flux

+ type FnSwitchOnFirst = func(s Signal, f Flux) Flux

+ type Processor interface

+ func NewUnicastProcessor() Processor

+ type Signal interface

+ Type func() rs.SignalType

+ Value func() (interface{}, bool)

Jul 7, 2019

Changes in this version

type Flux

+ func Empty() Flux

+ func Interval(period time.Duration) Flux

Jul 3, 2019

Changes in this version

+ type Flux interface

+ Filter func(rs.Predicate) Flux

+ Map func(rs.Transformer) Flux

+ SubscribeOn func(scheduler.Scheduler) Flux

+ func Create(c func(ctx context.Context, sink Sink)) Flux

+ func Just(first interface{}, others ...interface{}) Flux

+ type OverflowStrategy int8

+ const OverflowBuffer

+ const OverflowDrop

+ const OverflowError

+ const OverflowIgnore

+ const OverflowLatest

+ type Sink interface

+ Complete func()

+ Error func(error)

+ Next func(interface{})