channel

Documentation

Index

• func Iterator[A any](c <-chan A) iterable.Iterator[A]
• func Merge[A any](ctx context.Context, xs []<-chan A) <-chan A
• func Split[A any](ctx context.Context, in <-chan A, outs []chan<- A)
• type Channel
• type ReadOnlyChannel
  • func (r ReadOnlyChannel[A]) Iterator() iterable.Iterator[A]
• type WriteOnlyChannel

Functions

func Iterator

func Iterator[A any](c <-chan A) iterable.Iterator[A]

func Merge

func Merge[A any](ctx context.Context, xs []<-chan A) <-chan A

func Split

func Split[A any](ctx context.Context, in <-chan A, outs []chan<- A)

Split copies events from a single in channel to multiple out channels.

So, a broadcast.

Types

type Channel

type Channel[A any] chan A

type ReadOnlyChannel

type ReadOnlyChannel[A any] <-chan A

func (ReadOnlyChannel[A]) Iterator

func (r ReadOnlyChannel[A]) Iterator() iterable.Iterator[A]

type WriteOnlyChannel

type WriteOnlyChannel[A any] chan<- A