node

Apr 15, 2024

Changes in this version

+ func DoneAll(termNodes ...Doner) <-chan struct

+ func StartAll(startNodes ...Starter)

+ type Bypass struct

+ func (b *Bypass[INOUT]) InType() reflect.Type

+ func (b *Bypass[INOUT]) OutType() reflect.Type

+ func (b *Bypass[INOUT]) SendTo(r ...Receiver[INOUT])

+ type Doner interface

+ Done func() <-chan struct{}

+ type SenderReceiver interface

+ type Starter interface

+ Start func()

Oct 20, 2023

Changes in this version

+ func DemuxGet(d Demux, key any) chan<- OUT

+ type Demux struct

+ type Demuxed interface

+ type MiddleDemux struct

+ func AsMiddleDemux(fun MiddleDemuxFunc[IN], opts ...Option) *MiddleDemux[IN]

+ func (m *MiddleDemux[IN]) InType() reflect.Type

+ type MiddleDemuxFunc func(in <-chan IN, out Demux)

type Sender

+ func DemuxAdd(d Demuxed, key any) Sender[OUT]

type Start

+ func (i *Start) StartReceivers() (*connect.Forker[OUT], error)

+ type StartDemux struct

+ func AsStartDemux(funs ...StartDemuxFunc) *StartDemux

+ func (i *StartDemux) Start()

+ type StartDemuxFunc func(out Demux)

Sep 18, 2023

Changes in this version

type Middle

+ func (s *Middle[IN, OUT]) SendTo(outputs ...Receiver[OUT])

type Sender

+ SendTo func(...Receiver[OUT])

type Start

+ func (s *Start[OUT]) SendTo(outputs ...Receiver[OUT])

May 6, 2022

Changes in this version

type Start

+ func AsStartCtx(fun StartFuncCtx[OUT]) *Start[OUT]

+ func (i *Start[OUT]) StartCtx(ctx context.Context)

+ type StartFuncCtx func(ctx context.Context, out chan<- OUT)

Apr 9, 2022

Changes in this version

+ type Start struct

+ func AsStart(fun StartFunc[OUT]) *Start[OUT]

+ func (i *Start[OUT]) Start()

+ func (s *Start[OUT]) OutType() reflect.Type

+ func (s *Start[OUT]) SendsTo(outputs ...Receiver[OUT])

+ type StartFunc func(out chan<- OUT)

Mar 25, 2022

Changes in this version

+ type Option func(options *creationOptions)

+ func ChannelBufferLen(length int) Option

Mar 6, 2022

Changes in this version

+ type Init struct

+ func AsInit(fun InitFunc[OUT]) *Init[OUT]

+ func (i *Init[OUT]) Start()

+ func (s *Init[OUT]) OutType() reflect.Type

+ func (s *Init[OUT]) SendsTo(outputs ...Receiver[OUT])

+ type InitFunc func(out chan<- OUT)

+ type Middle struct

+ func AsMiddle(fun MiddleFunc[IN, OUT]) *Middle[IN, OUT]

+ func (m *Middle[IN, OUT]) InType() reflect.Type

+ func (m *Middle[IN, OUT]) OutType() reflect.Type

+ func (s *Middle[IN, OUT]) SendsTo(outputs ...Receiver[OUT])

+ type MiddleFunc func(in <-chan IN, out chan<- OUT)

+ type Receiver interface

+ InType func() reflect.Type

+ type Sender interface

+ OutType func() reflect.Type

+ SendsTo func(...Receiver[OUT])

+ type Terminal struct

+ func AsTerminal(fun TerminalFunc[IN]) *Terminal[IN]

+ func (m *Terminal[IN]) InType() reflect.Type

+ func (t *Terminal[IN]) Done() <-chan struct{}

+ type TerminalFunc func(out <-chan IN)