flux

package

v0.3.1 Latest Latest Go to latest Published: Aug 5, 2019 License: Apache-2.0 Imports: 8 Imported by: 13

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rsocket/rsocket-go

Links

Open Source Insights

Documentation ¶

Index ¶

func ToChannel(input Flux, ctx context.Context) (<-chan payload.Payload, <-chan error)
func ToChannelOnScheduler(input Flux, ctx context.Context, scheduler scheduler.Scheduler) (<-chan payload.Payload, <-chan error)
func ToChannelOnSchedulerWithSize(input Flux, ctx context.Context, scheduler scheduler.Scheduler, size int32) (<-chan payload.Payload, <-chan error)
func ToChannelWithSize(input Flux, ctx context.Context, size int32) (<-chan payload.Payload, <-chan error)
type Flux
type FnSwitchOnFirst
type Processor
- func CreateProcessor() Processor
type Signal
type Sink

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ToChannel ¶ added in v0.3.1

func ToChannel(input Flux, ctx context.Context) (<-chan payload.Payload, <-chan error)

func ToChannelOnScheduler ¶ added in v0.3.1

func ToChannelOnScheduler(input Flux, ctx context.Context, scheduler scheduler.Scheduler) (<-chan payload.Payload, <-chan error)

func ToChannelOnSchedulerWithSize ¶ added in v0.3.1

func ToChannelOnSchedulerWithSize(input Flux, ctx context.Context, scheduler scheduler.Scheduler, size int32) (<-chan payload.Payload, <-chan error)

func ToChannelWithSize ¶ added in v0.3.1

func ToChannelWithSize(input Flux, ctx context.Context, size int32) (<-chan payload.Payload, <-chan error)

Types ¶

type Flux ¶

type Flux interface {
	rx.Publisher
	Take(n int) Flux
	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
	Map(fn func(in payload.Payload) payload.Payload) Flux
	SwitchOnFirst(FnSwitchOnFirst) Flux
	SubscribeOn(scheduler.Scheduler) Flux
	Raw() flux.Flux
	BlockFirst(context.Context) (payload.Payload, error)
	BlockLast(context.Context) (payload.Payload, error)
	ToChan(ctx context.Context, cap int) (c <-chan payload.Payload, e <-chan error)
}

func Clone ¶

func Clone(source rx.Publisher) Flux

func Create ¶

func Create(gen func(ctx context.Context, s Sink)) Flux

func CreateFromChannel ¶ added in v0.3.1

func CreateFromChannel(payloads <-chan payload.Payload, err <-chan error) Flux

func Empty ¶

func Empty() Flux

func Error ¶ added in v0.3.1

func Error(err error) Flux

func Just ¶

func Just(payloads ...payload.Payload) Flux

func Raw ¶

func Raw(input flux.Flux) Flux

type FnSwitchOnFirst ¶

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

type Processor ¶

type Processor interface {
	Sink
	Flux
}

func CreateProcessor ¶

func CreateProcessor() Processor

type Signal ¶

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

type Sink ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL