mono

Documentation

Index

• 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 Sink

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
	// ToChan subscribe Mono and puts items into a chan.
	// It also puts errors into another chan.
	ToChan(ctx context.Context) (c <-chan payload.Payload, e <-chan error)
}

func Create

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

func CreateFromChannel

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

CreateFromChannel creates a Mono from channels.

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 Sink

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