pipe

package module

Go to main page

Versions in this module

v0

v0.2.3

Mar 22, 2023

Changes in this version

type Controller

+ func (b *Controller) BindContext(ctx context.Context, out chan<- T)

+ func (b *Controller) ListenContext(ctx context.Context) <-chan T

type ControllerM

+ func (b *ControllerM) BindContext(ctx context.Context, out chan<- T)

+ func (b *ControllerM) ListenContext(ctx context.Context) <-chan T

v0.2.2

Mar 15, 2023

v0.2.1

Mar 13, 2023

v0.2.0

Feb 10, 2023

Changes in this version

type BroadcasterCM

+ func (b *BroadcasterCM) Detach()

type Controller

+ func (c *Controller[T]) Send(value T) (ok bool)

type ControllerC

+ func (c *ControllerC[T]) Send(value T) (ok bool)

type ControllerCM

+ func (c *ControllerCM[T]) Send(value T) (ok bool)

type ControllerM

+ func (c *ControllerM[T]) Send(value T) (ok bool)

v0.1.1

Sep 9, 2022

v0.1.0

Sep 9, 2022

Changes in this version

+ func Converge2(ch1 <-chan A, ch2 <-chan B) <-chan any

+ func Converge3(ch1 <-chan A, ch2 <-chan B, ch3 <-chan C) <-chan any

+ func ConvergeN(chans ...any) <-chan any

+ func Until(b P, targets ...T)

+ func UntilContext(ctx context.Context, b P, targets ...T)

+ type Broadcaster struct

+ func Broadcast(upstream <-chan T) *Broadcaster[T]

+ func (b *Broadcaster) Bind(out chan<- T) CancelFunc

+ func (b *Broadcaster) Detach()

+ func (b *Broadcaster) Listen() (<-chan T, CancelFunc)

+ type BroadcasterC struct

+ func BroadcastC(in <-chan T) *BroadcasterC[T]

+ func (b *BroadcasterC) Until(targets ...T)

+ func (b *BroadcasterC) UntilCh(targets ...T) (<-chan struct{}, CancelFunc)

+ func (b *BroadcasterC) UntilContext(ctx context.Context, targets ...T)

+ type BroadcasterCM struct

+ func BroadcastCM(in <-chan T, initial T) *BroadcasterCM[T]

+ func (b *BroadcasterCM) Until(targets ...T)

+ func (b *BroadcasterCM) UntilCh(targets ...T) (<-chan struct{}, CancelFunc)

+ func (b *BroadcasterCM) UntilContext(ctx context.Context, targets ...T)

+ func (b *BroadcasterCM[T]) Current() T

+ type BroadcasterM struct

+ func BroadcastM(upstream <-chan T, initial T) *BroadcasterM[T]

+ func (b *BroadcasterM) Bind(out chan<- T) CancelFunc

+ func (b *BroadcasterM) Detach()

+ func (b *BroadcasterM) Listen() (<-chan T, CancelFunc)

+ func (b *BroadcasterM[T]) Current() T

+ type CancelFunc func()

+ func UntilCh(b P, targets ...T) (signalCh <-chan struct{}, canceller CancelFunc)

+ type Controller struct

+ func NewController() *Controller[T]

+ func (b *Controller) Bind(out chan<- T) CancelFunc

+ func (b *Controller) Detach()

+ func (b *Controller) Listen() (<-chan T, CancelFunc)

+ func (s Controller) Sink() chan<- T

+ type ControllerC struct

+ func NewControllerC() *ControllerC[T]

+ func (b *ControllerC) Until(targets ...T)

+ func (b *ControllerC) UntilCh(targets ...T) (<-chan struct{}, CancelFunc)

+ func (b *ControllerC) UntilContext(ctx context.Context, targets ...T)

+ func (s ControllerC) Sink() chan<- T

+ type ControllerCM struct

+ func NewControllerCM(initial T) *ControllerCM[T]

+ func (b *ControllerCM) Until(targets ...T)

+ func (b *ControllerCM) UntilCh(targets ...T) (<-chan struct{}, CancelFunc)

+ func (b *ControllerCM) UntilContext(ctx context.Context, targets ...T)

+ func (c *ControllerCM[T]) Current() T

+ func (s ControllerCM) Sink() chan<- T

+ type ControllerM struct

+ func NewControllerM(initial T) *ControllerM[T]

+ func (b *ControllerM) Bind(out chan<- T) CancelFunc

+ func (b *ControllerM) Detach()

+ func (b *ControllerM) Listen() (<-chan T, CancelFunc)

+ func (c *ControllerM[T]) Current() T

+ func (s ControllerM) Sink() chan<- T

+ type Listenable interface

+ Bind func(out chan<- T) CancelFunc

+ Listen func() (out <-chan T, cancel CancelFunc)

+ type ListenableC interface

+ Until func(...T)

+ UntilCh func(...T) (<-chan struct{}, CancelFunc)

+ UntilContext func(context.Context, ...T)

+ type ListenableCM interface

+ Current func() T

+ type ListenableM interface

+ Current func() T

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