streams

Documentation

Index

• type ErrorOutlet
• type Flow
• type Inlet
• type Outlet
• type Sink
• type Source

Types

type ErrorOutlet

type ErrorOutlet[E any] interface {
	ErrOut() <-chan E
}

type Flow

type Flow[I any, O any, E any] interface {
	Inlet[I]
	Outlet[O]
	ErrorOutlet[E]
	From(Outlet[I]) Flow[I, O, E]
	To(Inlet[O])
	Error(Inlet[E])
}

type Inlet

type Inlet[I any] interface {
	In() chan<- I
}

type Outlet

type Outlet[O any] interface {
	Out() <-chan O
}

type Sink

type Sink[I any] interface {
	Inlet[I]
}

type Source

type Source[O any] interface {
	Outlet[O]
}