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())
Output:
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlatMapper ¶ added in v0.2.4
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 JustOrEmpty ¶ added in v0.0.2
type Processor ¶ added in v0.0.3
func CreateProcessor ¶ added in v0.0.3
func CreateProcessor() Processor
Click to show internal directories.
Click to hide internal directories.