flux

type Flux interface {
	rx.Publisher
	Filter(rx.FnPredicate) Flux
	DoOnError(rx.FnOnError) Flux
	DoOnNext(rx.FnOnNext) Flux
	DoOnComplete(rx.FnOnComplete) Flux
	DoFinally(rx.FnFinally) Flux
	DoOnRequest(rx.FnOnRequest) Flux
	DoOnSubscribe(rx.FnOnSubscribe) Flux
	SwitchOnFirst(FnSwitchOnFirst) Flux
	SubscribeOn(scheduler.Scheduler) Flux
	Raw() flux.Flux
	BlockLast(context.Context) (payload.Payload, error)
}

type FnSwitchOnFirst = func(s Signal, f Flux) Flux

type Processor interface {
	Sink
	Flux
}

type Signal interface {
	Value() (payload.Payload, bool)
	Type() rx.SignalType
}

type Sink interface {
	Next(v payload.Payload)
	Complete()
	Error(e error)
}