mono

Documentation

Overview

Example

package main

import (
	"context"
	"fmt"

	rs "github.com/jjeffcaii/reactor-go"
	"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) + "!"
		}).
		Subscribe(context.Background(), rs.NewSubscriber(
			rs.OnNext(func(s rs.Subscription, v interface{}) {
				fmt.Println(v)
			}),
		))
}

Index

• type Mono
  • func Create(gen func(context.Context, Sink)) Mono
  • func Just(v interface{}) Mono
• type Sink

Examples

• Package

Types

type Mono

type Mono interface {
	rs.Publisher
	Filter(rs.Predicate) Mono
	Map(rs.Transformer) Mono
	SubscribeOn(scheduler.Scheduler) Mono
}

func Create

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

func Just

func Just(v interface{}) Mono

type Sink

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