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
• type Any
• 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
• type Processor
  • func CreateProcessor() Processor
• type Sink

Examples

• Package

Functions

func IsSubscribeAsync

func IsSubscribeAsync(m Mono) bool

Types

type Any

type Any = reactor.Any

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
	DelayElement(delay time.Duration) Mono
	Timeout(timeout time.Duration) Mono
}

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

type Processor

type Processor interface {
	Mono
	Sink
}

func CreateProcessor

func CreateProcessor() Processor

type Sink

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