rxgo

package module

Go to main page

Versions in this module

v2

v2.5.0

Apr 6, 2021

v2.4.0

Nov 5, 2020

v2.3.0

Oct 28, 2020

Changes in this version

type Observable

+ Find func(find Predicate, opts ...Option) OptionalSingle

type ObservableImpl

+ func (o *ObservableImpl) Find(find Predicate, opts ...Option) OptionalSingle

v2.2.0

Oct 2, 2020

Changes in this version

+ type GroupedObservable struct

+ Key int

type Observable

+ GroupByDynamic func(distribution func(Item) int, opts ...Option) Observable

type ObservableImpl

+ func (o *ObservableImpl) GroupByDynamic(distribution func(Item) int, opts ...Option) Observable

v2.1.1

Sep 22, 2020

v2.1.0

May 13, 2020

v2.0.1

Apr 28, 2020

v2.0.0

Mar 24, 2020

Changes in this version

+ var Infinite int64 = -1

+ var OptionalSingleEmpty = Item

+ func Assert(ctx context.Context, t *testing.T, iterable Iterable, assertions ...RxAssert)

+ func Just(items ...interface{}) func(opts ...Option) Observable

+ func SendItems(ctx context.Context, ch chan<- Item, strategy CloseChannelStrategy, ...)

+ type AssertPredicate func(items []interface{}) error

+ type BackpressureStrategy uint32

+ const Block

+ const Drop

+ type CloseChannelStrategy uint32

+ const CloseChannel

+ const LeaveChannelOpen

+ type Comparator func(interface{}, interface{}) int

+ type CompletedFunc func()

+ type Disposable context.CancelFunc

+ type Disposed <-chan struct

+ type Duration interface

+ func WithDuration(d time.Duration) Duration

+ type ErrFunc func(error)

+ type ErrorFunc func(error) interface

+ type ErrorToObservable func(error) Observable

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

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

+ type FuncN func(...interface{}) interface

+ type IllegalInputError struct

+ func (e IllegalInputError) Error() string

+ type IndexOutOfBoundError struct

+ func (e IndexOutOfBoundError) Error() string

+ type Item struct

+ E error

+ V interface{}

+ func Error(err error) Item

+ func Of(i interface{}) Item

+ func (i Item) Error() bool

+ func (i Item) SendBlocking(ch chan<- Item)

+ func (i Item) SendContext(ctx context.Context, ch chan<- Item) bool

+ func (i Item) SendNonBlocking(ch chan<- Item) bool

+ type ItemToObservable func(Item) Observable

+ type Iterable interface

+ Observe func(opts ...Option) <-chan Item

+ type Marshaller func(interface{}) ([]byte, error)

+ type NextFunc func(interface{})

+ type Observable interface

+ All func(predicate Predicate, opts ...Option) Single

+ AverageFloat32 func(opts ...Option) Single

+ AverageFloat64 func(opts ...Option) Single

+ AverageInt func(opts ...Option) Single

+ AverageInt16 func(opts ...Option) Single

+ AverageInt32 func(opts ...Option) Single

+ AverageInt64 func(opts ...Option) Single

+ AverageInt8 func(opts ...Option) Single

+ BackOffRetry func(backOffCfg backoff.BackOff, opts ...Option) Observable

+ BufferWithCount func(count int, opts ...Option) Observable

+ BufferWithTime func(timespan Duration, opts ...Option) Observable

+ BufferWithTimeOrCount func(timespan Duration, count int, opts ...Option) Observable

+ Connect func() Disposable

+ Contains func(equal Predicate, opts ...Option) Single

+ Count func(opts ...Option) Single

+ Debounce func(timespan Duration, opts ...Option) Observable

+ DefaultIfEmpty func(defaultValue interface{}, opts ...Option) Observable

+ Distinct func(apply Func, opts ...Option) Observable

+ DistinctUntilChanged func(apply Func, opts ...Option) Observable

+ DoOnCompleted func(completedFunc CompletedFunc, opts ...Option) Disposed

+ DoOnError func(errFunc ErrFunc, opts ...Option) Disposed

+ DoOnNext func(nextFunc NextFunc, opts ...Option) Disposed

+ ElementAt func(index uint, opts ...Option) Single

+ Error func(opts ...Option) error

+ Errors func(opts ...Option) []error

+ Filter func(apply Predicate, opts ...Option) Observable

+ First func(opts ...Option) OptionalSingle

+ FirstOrDefault func(defaultValue interface{}, opts ...Option) Single

+ FlatMap func(apply ItemToObservable, opts ...Option) Observable

+ ForEach func(nextFunc NextFunc, errFunc ErrFunc, completedFunc CompletedFunc, ...) Disposed

+ GroupBy func(length int, distribution func(Item) int, opts ...Option) Observable

+ IgnoreElements func(opts ...Option) Observable

+ Join func(joiner Func2, right Observable, timeExtractor func(interface{}) time.Time, ...) Observable

+ Last func(opts ...Option) OptionalSingle

+ LastOrDefault func(defaultValue interface{}, opts ...Option) Single

+ Map func(apply Func, opts ...Option) Observable

+ Marshal func(marshaller Marshaller, opts ...Option) Observable

+ Max func(comparator Comparator, opts ...Option) OptionalSingle

+ Min func(comparator Comparator, opts ...Option) OptionalSingle

+ OnErrorResumeNext func(resumeSequence ErrorToObservable, opts ...Option) Observable

+ OnErrorReturn func(resumeFunc ErrorFunc, opts ...Option) Observable

+ OnErrorReturnItem func(resume interface{}, opts ...Option) Observable

+ Reduce func(apply Func2, opts ...Option) OptionalSingle

+ Repeat func(count int64, frequency Duration, opts ...Option) Observable

+ Retry func(count int, shouldRetry func(error) bool, opts ...Option) Observable

+ Run func(opts ...Option) Disposed

+ Sample func(iterable Iterable, opts ...Option) Observable

+ Scan func(apply Func2, opts ...Option) Observable

+ Send func(output chan<- Item, opts ...Option)

+ SequenceEqual func(iterable Iterable, opts ...Option) Single

+ Serialize func(from int, identifier func(interface{}) int, opts ...Option) Observable

+ Skip func(nth uint, opts ...Option) Observable

+ SkipLast func(nth uint, opts ...Option) Observable

+ SkipWhile func(apply Predicate, opts ...Option) Observable

+ StartWith func(iterable Iterable, opts ...Option) Observable

+ SumFloat32 func(opts ...Option) OptionalSingle

+ SumFloat64 func(opts ...Option) OptionalSingle

+ SumInt64 func(opts ...Option) OptionalSingle

+ Take func(nth uint, opts ...Option) Observable

+ TakeLast func(nth uint, opts ...Option) Observable

+ TakeUntil func(apply Predicate, opts ...Option) Observable

+ TakeWhile func(apply Predicate, opts ...Option) Observable

+ TimeInterval func(opts ...Option) Observable

+ Timestamp func(opts ...Option) Observable

+ ToMap func(keySelector Func, opts ...Option) Single

+ ToMapWithValueSelector func(keySelector, valueSelector Func, opts ...Option) Single

+ ToSlice func(initialCapacity int, opts ...Option) ([]interface{}, error)

+ Unmarshal func(unmarshaller Unmarshaller, factory func() interface{}, opts ...Option) Observable

+ WindowWithCount func(count int, opts ...Option) Observable

+ WindowWithTime func(timespan Duration, opts ...Option) Observable

+ WindowWithTimeOrCount func(timespan Duration, count int, opts ...Option) Observable

+ ZipFromIterable func(iterable Iterable, zipper Func2, opts ...Option) Observable

+ func Amb(observables []Observable, opts ...Option) Observable

+ func CombineLatest(f FuncN, observables []Observable, opts ...Option) Observable

+ func Concat(observables []Observable, opts ...Option) Observable

+ func Create(f []Producer, opts ...Option) Observable

+ func Defer(f []Producer, opts ...Option) Observable

+ func Empty() Observable

+ func FromChannel(next <-chan Item, opts ...Option) Observable

+ func FromEventSource(next <-chan Item, opts ...Option) Observable

+ func Interval(interval Duration, opts ...Option) Observable

+ func Merge(observables []Observable, opts ...Option) Observable

+ func Never() Observable

+ func Range(start, count int, opts ...Option) Observable

+ func Start(fs []Supplier, opts ...Option) Observable

+ func Thrown(err error) Observable

+ func Timer(d Duration, opts ...Option) Observable

+ type ObservableImpl struct

+ func (o *ObservableImpl) All(predicate Predicate, opts ...Option) Single

+ func (o *ObservableImpl) AverageFloat32(opts ...Option) Single

+ func (o *ObservableImpl) AverageFloat64(opts ...Option) Single

+ func (o *ObservableImpl) AverageInt(opts ...Option) Single

+ func (o *ObservableImpl) AverageInt16(opts ...Option) Single

+ func (o *ObservableImpl) AverageInt32(opts ...Option) Single

+ func (o *ObservableImpl) AverageInt64(opts ...Option) Single

+ func (o *ObservableImpl) AverageInt8(opts ...Option) Single

+ func (o *ObservableImpl) BackOffRetry(backOffCfg backoff.BackOff, opts ...Option) Observable

+ func (o *ObservableImpl) BufferWithCount(count int, opts ...Option) Observable

+ func (o *ObservableImpl) BufferWithTime(timespan Duration, opts ...Option) Observable

+ func (o *ObservableImpl) BufferWithTimeOrCount(timespan Duration, count int, opts ...Option) Observable

+ func (o *ObservableImpl) Connect() Disposable

+ func (o *ObservableImpl) Contains(equal Predicate, opts ...Option) Single

+ func (o *ObservableImpl) Count(opts ...Option) Single

+ func (o *ObservableImpl) Debounce(timespan Duration, opts ...Option) Observable

+ func (o *ObservableImpl) DefaultIfEmpty(defaultValue interface{}, opts ...Option) Observable

+ func (o *ObservableImpl) Distinct(apply Func, opts ...Option) Observable

+ func (o *ObservableImpl) DistinctUntilChanged(apply Func, opts ...Option) Observable

+ func (o *ObservableImpl) DoOnCompleted(completedFunc CompletedFunc, opts ...Option) Disposed

+ func (o *ObservableImpl) DoOnError(errFunc ErrFunc, opts ...Option) Disposed

+ func (o *ObservableImpl) DoOnNext(nextFunc NextFunc, opts ...Option) Disposed

+ func (o *ObservableImpl) ElementAt(index uint, opts ...Option) Single

+ func (o *ObservableImpl) Error(opts ...Option) error

+ func (o *ObservableImpl) Errors(opts ...Option) []error

+ func (o *ObservableImpl) Filter(apply Predicate, opts ...Option) Observable

+ func (o *ObservableImpl) First(opts ...Option) OptionalSingle

+ func (o *ObservableImpl) FirstOrDefault(defaultValue interface{}, opts ...Option) Single

+ func (o *ObservableImpl) FlatMap(apply ItemToObservable, opts ...Option) Observable

+ func (o *ObservableImpl) ForEach(nextFunc NextFunc, errFunc ErrFunc, completedFunc CompletedFunc, ...) Disposed

+ func (o *ObservableImpl) GroupBy(length int, distribution func(Item) int, opts ...Option) Observable

+ func (o *ObservableImpl) IgnoreElements(opts ...Option) Observable

+ func (o *ObservableImpl) Join(joiner Func2, right Observable, timeExtractor func(interface{}) time.Time, ...) Observable

+ func (o *ObservableImpl) Last(opts ...Option) OptionalSingle

+ func (o *ObservableImpl) LastOrDefault(defaultValue interface{}, opts ...Option) Single

+ func (o *ObservableImpl) Map(apply Func, opts ...Option) Observable

+ func (o *ObservableImpl) Marshal(marshaller Marshaller, opts ...Option) Observable

+ func (o *ObservableImpl) Max(comparator Comparator, opts ...Option) OptionalSingle

+ func (o *ObservableImpl) Min(comparator Comparator, opts ...Option) OptionalSingle

+ func (o *ObservableImpl) Observe(opts ...Option) <-chan Item

+ func (o *ObservableImpl) OnErrorResumeNext(resumeSequence ErrorToObservable, opts ...Option) Observable

+ func (o *ObservableImpl) OnErrorReturn(resumeFunc ErrorFunc, opts ...Option) Observable

+ func (o *ObservableImpl) OnErrorReturnItem(resume interface{}, opts ...Option) Observable

+ func (o *ObservableImpl) Reduce(apply Func2, opts ...Option) OptionalSingle

+ func (o *ObservableImpl) Repeat(count int64, frequency Duration, opts ...Option) Observable

+ func (o *ObservableImpl) Retry(count int, shouldRetry func(error) bool, opts ...Option) Observable

+ func (o *ObservableImpl) Run(opts ...Option) Disposed

+ func (o *ObservableImpl) Sample(iterable Iterable, opts ...Option) Observable

+ func (o *ObservableImpl) Scan(apply Func2, opts ...Option) Observable

+ func (o *ObservableImpl) Send(output chan<- Item, opts ...Option)

+ func (o *ObservableImpl) SequenceEqual(iterable Iterable, opts ...Option) Single

+ func (o *ObservableImpl) Serialize(from int, identifier func(interface{}) int, opts ...Option) Observable

+ func (o *ObservableImpl) Skip(nth uint, opts ...Option) Observable

+ func (o *ObservableImpl) SkipLast(nth uint, opts ...Option) Observable

+ func (o *ObservableImpl) SkipWhile(apply Predicate, opts ...Option) Observable

+ func (o *ObservableImpl) StartWith(iterable Iterable, opts ...Option) Observable

+ func (o *ObservableImpl) SumFloat32(opts ...Option) OptionalSingle

+ func (o *ObservableImpl) SumFloat64(opts ...Option) OptionalSingle

+ func (o *ObservableImpl) SumInt64(opts ...Option) OptionalSingle

+ func (o *ObservableImpl) Take(nth uint, opts ...Option) Observable

+ func (o *ObservableImpl) TakeLast(nth uint, opts ...Option) Observable

+ func (o *ObservableImpl) TakeUntil(apply Predicate, opts ...Option) Observable

+ func (o *ObservableImpl) TakeWhile(apply Predicate, opts ...Option) Observable

+ func (o *ObservableImpl) TimeInterval(opts ...Option) Observable

+ func (o *ObservableImpl) Timestamp(opts ...Option) Observable

+ func (o *ObservableImpl) ToMap(keySelector Func, opts ...Option) Single

+ func (o *ObservableImpl) ToMapWithValueSelector(keySelector, valueSelector Func, opts ...Option) Single

+ func (o *ObservableImpl) ToSlice(initialCapacity int, opts ...Option) ([]interface{}, error)

+ func (o *ObservableImpl) Unmarshal(unmarshaller Unmarshaller, factory func() interface{}, opts ...Option) Observable

+ func (o *ObservableImpl) WindowWithCount(count int, opts ...Option) Observable

+ func (o *ObservableImpl) WindowWithTime(timespan Duration, opts ...Option) Observable

+ func (o *ObservableImpl) WindowWithTimeOrCount(timespan Duration, count int, opts ...Option) Observable

+ func (o *ObservableImpl) ZipFromIterable(iterable Iterable, zipper Func2, opts ...Option) Observable

+ type ObservationStrategy uint32

+ const Eager

+ const Lazy

+ type OnErrorStrategy uint32

+ const ContinueOnError

+ const StopOnError

+ type Option interface

+ func Serialize(identifier func(interface{}) int) Option

+ func WithBackPressureStrategy(strategy BackpressureStrategy) Option

+ func WithBufferedChannel(capacity int) Option

+ func WithCPUPool() Option

+ func WithContext(ctx context.Context) Option

+ func WithErrorStrategy(strategy OnErrorStrategy) Option

+ func WithObservationStrategy(strategy ObservationStrategy) Option

+ func WithPool(pool int) Option

+ func WithPublishStrategy() Option

+ type OptionalSingle interface

+ Get func(opts ...Option) (Item, error)

+ Map func(apply Func, opts ...Option) OptionalSingle

+ Run func(opts ...Option) Disposed

+ type OptionalSingleImpl struct

+ func (o *OptionalSingleImpl) Get(opts ...Option) (Item, error)

+ func (o *OptionalSingleImpl) Map(apply Func, opts ...Option) OptionalSingle

+ func (o *OptionalSingleImpl) Observe(opts ...Option) <-chan Item

+ func (o *OptionalSingleImpl) Run(opts ...Option) Disposed

+ type Predicate func(interface{}) bool

+ type Producer func(ctx context.Context, next chan<- Item)

+ type RxAssert interface

+ func CustomPredicate(predicate AssertPredicate) RxAssert

+ func HasAnError() RxAssert

+ func HasError(err error) RxAssert

+ func HasErrors(errs ...error) RxAssert

+ func HasItem(i interface{}) RxAssert

+ func HasItems(items ...interface{}) RxAssert

+ func HasItemsNoOrder(items ...interface{}) RxAssert

+ func HasNoError() RxAssert

+ func IsEmpty() RxAssert

+ func IsNotEmpty() RxAssert

+ type Single interface

+ Filter func(apply Predicate, opts ...Option) OptionalSingle

+ Get func(opts ...Option) (Item, error)

+ Map func(apply Func, opts ...Option) Single

+ Run func(opts ...Option) Disposed

+ func JustItem(item interface{}, opts ...Option) Single

+ type SingleImpl struct

+ func (s *SingleImpl) Filter(apply Predicate, opts ...Option) OptionalSingle

+ func (s *SingleImpl) Get(opts ...Option) (Item, error)

+ func (s *SingleImpl) Map(apply Func, opts ...Option) Single

+ func (s *SingleImpl) Observe(opts ...Option) <-chan Item

+ func (s *SingleImpl) Run(opts ...Option) Disposed

+ type Supplier func(ctx context.Context) Item

+ type TimestampItem struct

+ Timestamp time.Time

+ V interface{}

+ type Unmarshaller func([]byte, interface{}) error

v2.0.0-beta.3

Mar 22, 2020

v2.0.0-beta.2

Feb 26, 2020

v2.0.0-beta.1

Feb 23, 2020

Other modules containing this package

github.com/reactivex/rxgo

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL