gorx

README

gorx

Reactive Extension for golang

Documentation

Index

• type Disposable
• type DisposableState
• type EmitSequence
• type EmitterBuilder
  • func NewEmitterBuilder() EmitterBuilder
• type Observable
• type ObservableSource
• type Observer
• type Runnable
• type SubscribedObserver

Types

type Disposable

type Disposable interface {
	Dispose()
	DisposableState
}

type DisposableState

type DisposableState interface {
	IsDisposed() bool
}

type EmitSequence

type EmitSequence func(Observer, DisposableState)

type EmitterBuilder

type EmitterBuilder interface {
	EmitNext(el string) EmitterBuilder
	EmitError(err error) EmitterBuilder
	EmitComplete() EmitterBuilder
	Build() EmitSequence
}

func NewEmitterBuilder

func NewEmitterBuilder() EmitterBuilder

type Observable

type Observable interface {
	ObservableSource
}

type ObservableSource

type ObservableSource interface {
	ConcatWith(observable Observable) Observable

	OnErrorResumeNext(resumeFunc func(err error) Observable) Observable
	OnErrorResumeWith(observable Observable) Observable
	OnErrorReturn(element interface{}) Observable

	FlatMap(mapFunc func(interface{}) Observable) Observable
	Map(mapFunc func(interface{}) interface{}) Observable

	Subscribe(emissionObserver Observer) Disposable
}

type Observer

type Observer interface {
	OnNext(element interface{})
	OnError(err error)
	OnComplete()
}

type Runnable

type Runnable interface {
	Run()
}

type SubscribedObserver

type SubscribedObserver interface {
	OnSubscribe(emitSequence EmitSequence, subscription Disposable)
}