Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

chantools

package module

Go to main page

Versions in this module

v0

v0.0.5

Apr 12, 2024

v0.0.4

Apr 12, 2024

Changes in this version

+ func Concat[E any, C <-chan E](inputs ...C) []E

+ func NewSyncWithErr[C any](worker func(c chan<- C, eC chan<- error, params ...any), ...) ([]C, []error)

+ func NewSync[C any](worker func(c chan<- C, params ...any), option ...NewChanOptions[C]) []C

v0.0.3

Mar 29, 2024

Changes in this version

+ func Flatten[I any](input <-chan []I) <-chan I

+ func Map[I any, O any](input <-chan I, mapper func(input I) O, option ...NewChanOptions[O]) <-chan O

type NewChanOptions

+ func WithContext[I any](ctx context.Context) NewChanOptions[I]

+ func WithName[I any](name string) NewChanOptions[I]

+ func WithNonManagedChannel[I any]() NewChanOptions[I]

v0.0.2

Feb 29, 2024

Changes in this version

+ func Merge[E any](inputs ...<-chan E) <-chan E

+ func NewWithErr[C any](worker func(c chan<- C, eC chan<- error, params ...any), ...) (<-chan C, <-chan error)

+ func NewWriter(c chan<- []byte) io.WriteCloser

+ func New[C any](worker func(c chan<- C, params ...any), option ...NewChanOptions[C]) <-chan C

+ func Once[C any](value C) <-chan C

+ type ChanWriter struct

+ func (cw *ChanWriter) Close() error

+ func (cw *ChanWriter) Write(data []byte) (int, error)

+ type NewChanOptions func(ct *chanToolsConfig[I])

+ func WithBuffer[I any](count int64) NewChanOptions[I]

+ func WithLastValue[I any](lasValue I) NewChanOptions[I]

+ func WithNonBlocking[I any]() NewChanOptions[I]

+ func WithParam[I any](p ...any) NewChanOptions[I]

v0.0.1

Apr 28, 2023

Changes in this version

+ func Broadcast(src <-chan T, qty uint) []<-chan T

+ func BroadcastSync(src <-chan T, qty uint) []<-chan T

+ func CastTo(ch <-chan any) <-chan T

+ func CastToAny(ch <-chan T) <-chan any

+ func CastToReader(ch []chan T) []<-chan T

+ func ChanBuffErrGenerator(worker func(chan<- C, chan<- error), count int, ...) (<-chan C, <-chan error)

+ func ChanBuffGenerator(worker func(chan<- C), count int, extensions ...ChanGeneratorExtension[C]) <-chan C

+ func ChanErrGenerator(worker func(c chan<- C, err chan<- error), ...) (<-chan C, <-chan error)

+ func ChanGenerator(worker func(chan<- C), extensions ...ChanGeneratorExtension[C]) <-chan C

+ func FlatChan(input <-chan []I) <-chan I

+ func ForEach(inputSlice []T, each func(input T))

+ func ForEachChan(src <-chan T, each func(element T))

+ func ForwardIf(src <-chan T, where func(element T) bool, ...) <-chan T

+ func ForwardTo(ctx context.Context, src <-chan T, dst chan<- T, ...)

+ func MakeSliceChan(qty uint) []chan T

+ func MapChan(input <-chan I, mapper func(input I) (O, error), ...) (<-chan O, <-chan error)

+ func MapSlice(input []I, mapper func(input I) O) []O

+ func MergeChan(inputs ...<-chan E) <-chan E

+ func MergeMap(elem ...map[K]V) (map[K]V, error)

+ func Tick(ctx context.Context, interval time.Duration, generate func() (I, error)) (<-chan I, <-chan error)

+ func WithInitialValue(initialValue I) func(c chan<- I)

+ type BrokerChan struct

+ func NewBrokerChan(src <-chan E) *BrokerChan[E]

+ func (bc *BrokerChan[E]) Subscribe() <-chan E

+ type ChanGeneratorExtension func(c chan<- I)

+ type ForwardToExtensions func(c I) error

+ type ListenProperty struct

+ func Listen(initialProperty E) *ListenProperty[E]

+ func ListenChan(ctx context.Context, initialProperty E, src <-chan E) *ListenProperty[E]

+ func ListenWithContext(ctx context.Context, initialProperty E) *ListenProperty[E]

+ func (lp *ListenProperty[E]) Forward(ctx context.Context, i <-chan E)

+ func (lp *ListenProperty[E]) Set(value E)

+ func (lp ListenProperty[E]) Close()

+ func (lp ListenProperty[E]) Updates() <-chan E

+ func (lp ListenProperty[E]) Value() E