mono

Documentation

Index

• func ToChannel(input Mono, ctx context.Context) (<-chan payload.Payload, <-chan error)
• func ToChannelOnScheduler(input Mono, ctx context.Context, scheduler scheduler.Scheduler) (<-chan payload.Payload, <-chan error)
• type Mono
  • func Create(gen func(context.Context, Sink)) Mono
  • func CreateFromChannel(payloads <-chan payload.Payload, err <-chan error) Mono
  • func Empty() Mono
  • func Error(err error) Mono
  • func Just(input payload.Payload) Mono
  • func JustOrEmpty(input payload.Payload) Mono
  • func Raw(input mono.Mono) Mono
• type Processor
  • func CreateProcessor() Processor
• type RawPublisher
• type Sink

Functions

func ToChannel

func ToChannel(input Mono, ctx context.Context) (<-chan payload.Payload, <-chan error)

func ToChannelOnScheduler

func ToChannelOnScheduler(input Mono, ctx context.Context, scheduler scheduler.Scheduler) (<-chan payload.Payload, <-chan error)

Types

type Mono

type Mono interface {
	rx.Publisher
	Filter(rx.FnPredicate) Mono
	DoFinally(rx.FnFinally) Mono
	DoOnError(rx.FnOnError) Mono
	DoOnSuccess(rx.FnOnNext) Mono
	DoOnCancel(rx.FnOnCancel) Mono
	DoOnSubscribe(rx.FnOnSubscribe) Mono
	SubscribeOn(scheduler.Scheduler) Mono
	Block(context.Context) (payload.Payload, error)
	SwitchIfEmpty(alternative Mono) Mono
	Raw() mono.Mono
}

func Create

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

func CreateFromChannel

func CreateFromChannel(payloads <-chan payload.Payload, err <-chan error) Mono

func Empty

func Empty() Mono

func Error

func Error(err error) Mono

func Just

func Just(input payload.Payload) Mono

func JustOrEmpty

func JustOrEmpty(input payload.Payload) Mono

func Raw

func Raw(input mono.Mono) Mono

type Processor

type Processor interface {
	Sink
	Mono
}

func CreateProcessor

func CreateProcessor() Processor

type RawPublisher

type RawPublisher interface {
	SubscribeWith(context.Context, rx.Subscriber)
}

type Sink

type Sink interface {
	Success(payload.Payload)
	Error(error)
}