filter

package

v0.0.0 Latest Latest Go to latest Published: Jul 20, 2026 License: GPL-3.0 Imports: 0 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Binary[X any] struct {
	Input <-chan X
	True  chan<- X
	False chan<- X
	Func  func(X) bool
}

func (b *Binary[X]) Work(ctx context.Context) error

type Drop[X any] struct {
	Input  <-chan X
	Output chan<- X
	Func   func(X) bool
}

func (d *Drop[X]) Work(ctx context.Context) error

type Multi[X any, K comparable] struct {
	Input  <-chan X
	Output map[K](chan<- X)
	Func   func(X) K
}

func (m *Multi[X, K]) Work(ctx context.Context) error