Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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
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

consume2

package module

Go to main page

Versions in this module

v0

v0.7.0

Nov 9, 2023

Changes in this version

type Pipeline

+ func (p Pipeline[T, U]) Call(f func(value U)) Consumer[T]

v0.6.0

Mar 22, 2023

Changes in this version

type Pipeline

+ func Identity() Pipeline[T, T]

v0.5.0

Mar 17, 2023

Changes in this version

+ func FromGenerator(generator func() (T, bool), consumer Consumer[T])

+ func FromIntGenerator(generator func() int, consumer Consumer[int])

+ func FromPtrSlice(aslice []*T, consumer Consumer[T])

+ func FromSlice(aslice []T, consumer Consumer[T])

+ type Pipeline func(inner Consumer[U]) Consumer[T]

+ func Join(left Pipeline[T, U], right Pipeline[U, V]) Pipeline[T, V]

+ func PFilter(filter func(value T) bool) Pipeline[T, T]

+ func PFilterp(filter func(ptr *T) bool) Pipeline[T, T]

+ func PMap(mapper func(T) U) Pipeline[T, U]

+ func PMaybeMap(mapper func(T) (U, bool)) Pipeline[T, U]

+ func PSlice(start, end int) Pipeline[T, T]

+ func PTakeWhile(filter func(value T) bool) Pipeline[T, T]

+ func (p Pipeline[T, U]) AppendTo(aSlicePtr *[]U) Consumer[T]

+ func (p Pipeline[T, U]) Run(consumer Consumer[U]) Consumer[T]

v0.4.0

May 25, 2022

Changes in this version

+ func AsFunc(consumer Consumer[T]) func(T) bool

v0.3.0

May 14, 2022

v0.2.0

May 1, 2022

v0.1.0

Jan 26, 2022

Changes in this version

+ func ComposeFilters(filters ...func(T) bool) func(T) bool

+ func MustCanConsume(c Consumer[T])

+ type Consumer interface

+ CanConsume func() bool

+ Consume func(value T)

+ func AppendPtrsTo(aSlicePtr *[]*T) Consumer[T]

+ func AppendTo(aSlicePtr *[]T) Consumer[T]

+ func Compose(consumers ...Consumer[T]) Consumer[T]

+ func Filter(consumer Consumer[T], filter func(value T) bool) Consumer[T]

+ func Filterp(consumer Consumer[T], filter func(ptr *T) bool) Consumer[T]

+ func Map(consumer Consumer[U], mapper func(T) U) Consumer[T]

+ func MaybeMap(consumer Consumer[U], mapper func(T) (U, bool)) Consumer[T]

+ func Nil() Consumer[T]

+ func Slice(consumer Consumer[T], start, end int) Consumer[T]

+ func TakeWhile(consumer Consumer[T], filter func(value T) bool) Consumer[T]

+ type ConsumerFunc func(value T)

+ func (c ConsumerFunc[T]) CanConsume() bool

+ func (c ConsumerFunc[T]) Consume(value T)

+ type NoGenerics struct

+ func NewNoGenerics(consumer Consumer[T]) *NoGenerics[T]

+ func (n *NoGenerics[T]) CanConsume() bool

+ func (n *NoGenerics[T]) Consume(ptr interface{})

+ type PageBuilder struct

+ func NewPageBuilder(zeroBasedPageNo int, valuesPerPage int) *PageBuilder[T]

+ func (p *PageBuilder[T]) Build() (values []T, morePages bool)

+ func (p *PageBuilder[T]) CanConsume() bool

+ func (p *PageBuilder[T]) Consume(value T)