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
}

type Processor interface {
	Sink
	Mono
}

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

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