mono

Documentation

Overview

Example

gen := func(ctx context.Context, sink mono.Sink) {
	sink.Success("World")
}
mono.
	Create(gen).
	Map(func(i Any) (o Any, err error) {
		o = "Hello " + i.(string) + "!"
		return
	}).
	DoOnNext(func(v Any) error {
		fmt.Println(v)
		return nil
	}).
	Subscribe(context.Background())

Index

• func IsSubscribeAsync(m Mono) bool
• func NewProcessor(sc scheduler.Scheduler, hook ProcessorFinallyHook) (Mono, Sink, Disposable)
• type Any
• type Disposable
• type FlatMapper
• type Mono
  • func Create(gen func(ctx context.Context, s Sink)) Mono
  • func CreateOneshot(gen func(ctx context.Context, s Sink)) Mono
  • func Delay(delay time.Duration) Mono
  • func Empty() Mono
  • func Error(e error) Mono
  • func ErrorOneshot(e error) Mono
  • func Just(v Any) Mono
  • func JustOneshot(v Any) Mono
  • func JustOrEmpty(v Any) Mono
  • func Zip(first, second Mono, others ...Mono) Mono
  • func ZipAll(all ...Mono) Mono
• type Processor
• type ProcessorFinallyHook
• type Sink

Examples

• Package

Functions

func IsSubscribeAsync

func IsSubscribeAsync(m Mono) bool

func NewProcessor

func NewProcessor(sc scheduler.Scheduler, hook ProcessorFinallyHook) (Mono, Sink, Disposable)

Types

type Any

type Any = reactor.Any

Alias

type Disposable

type Disposable = reactor.Disposable

Alias

type FlatMapper

type FlatMapper = func(reactor.Any) Mono

type Mono

type Mono interface {
	reactor.Publisher
	Filter(reactor.Predicate) Mono
	Map(reactor.Transformer) Mono
	FlatMap(FlatMapper) Mono
	SubscribeOn(scheduler.Scheduler) Mono
	Block(context.Context) (Any, error)
	DoOnNext(reactor.FnOnNext) Mono
	DoOnComplete(reactor.FnOnComplete) Mono
	DoOnSubscribe(reactor.FnOnSubscribe) Mono
	DoOnError(reactor.FnOnError) Mono
	DoOnCancel(reactor.FnOnCancel) Mono
	DoFinally(reactor.FnOnFinally) Mono
	DoOnDiscard(reactor.FnOnDiscard) Mono
	SwitchIfEmpty(alternative Mono) Mono
	SwitchIfError(alternative func(error) Mono) Mono
	SwitchValueIfError(v Any) Mono
	DelayElement(delay time.Duration) Mono
	Timeout(timeout time.Duration) Mono
	Raw() reactor.RawPublisher
}

func Create

func Create(gen func(ctx context.Context, s Sink)) Mono

func CreateOneshot

func CreateOneshot(gen func(ctx context.Context, s Sink)) Mono

func Delay

func Delay(delay time.Duration) Mono

func Empty

func Empty() Mono

func Error

func Error(e error) Mono

func ErrorOneshot

func ErrorOneshot(e error) Mono

func Just

func Just(v Any) Mono

func JustOneshot

func JustOneshot(v Any) Mono

func JustOrEmpty

func JustOrEmpty(v Any) Mono

func Zip

func Zip(first, second Mono, others ...Mono) Mono

func ZipAll

func ZipAll(all ...Mono) Mono

type Processor

type Processor interface {
	Mono
	Sink
}

type ProcessorFinallyHook

type ProcessorFinallyHook func(reactor.SignalType, reactor.Disposable)

type Sink

type Sink interface {
	Success(Any)
	Error(error)
}