mono

Documentation

Overview

Example

package main

import (
	"context"
	"fmt"

	"github.com/jjeffcaii/reactor-go/mono"
)

func main() {
	gen := func(ctx context.Context, sink mono.Sink) {
		sink.Success("World")
	}
	mono.
		Create(gen).
		Map(func(i interface{}) interface{} {
			return "Hello " + i.(string) + "!"
		}).
		DoOnNext(func(v interface{}) {
			fmt.Println(v)
		}).
		Subscribe(context.Background())
}

Index

• type Mono
  • func Create(gen func(context.Context, Sink)) Mono
  • func Delay(delay time.Duration) Mono
  • func Empty() Mono
  • func Just(v interface{}) Mono
  • func JustOrEmpty(v interface{}) Mono
• type Processor
  • func CreateProcessor() Processor
• type Sink

Examples

• Package

Types

type Mono

type Mono interface {
	rs.Publisher
	Filter(rs.Predicate) Mono
	Map(rs.Transformer) Mono
	FlatMap(flatMapper) Mono
	SubscribeOn(scheduler.Scheduler) Mono
	Block(context.Context) (interface{}, error)
	DoOnNext(rs.FnOnNext) Mono
	DoOnComplete(rs.FnOnComplete) Mono
	DoOnSubscribe(rs.FnOnSubscribe) Mono
	DoOnError(rs.FnOnError) Mono
	DoOnCancel(rs.FnOnCancel) Mono
	DoFinally(rs.FnOnFinally) Mono
	DoOnDiscard(rs.FnOnDiscard) Mono
	SwitchIfEmpty(alternative Mono) Mono
	DelayElement(delay time.Duration) Mono
}

func Create

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

func Delay

func Delay(delay time.Duration) Mono

func Empty

func Empty() Mono

func Just

func Just(v interface{}) Mono

func JustOrEmpty

func JustOrEmpty(v interface{}) Mono

type Processor

type Processor interface {
	Mono
	Sink
}

func CreateProcessor

func CreateProcessor() Processor

type Sink

type Sink interface {
	Success(interface{})
	Error(error)
}