channels

package

v8.56.1709838579-SHA-e... Latest Latest Go to latest Published: Mar 8, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package channels provide some simple adapters to facilitate common read/write patterns.

This section is empty.

This section is empty.

func MapBetween[A, B any](src Source[A], dst Sink[B], fn MapFn[A, B]) task.Task

type MapFn[A, B any] func(context.Context, A) (B, error)

type Receiver[T any] func() (T, error)

type Sender[T any] func(T) error

type Sink[T any] chan<- T

func NewSink[T any](c chan<- T) Sink[T]

NewSink takes a writable channel and returns a Sink, which can be used to chain common transformations fluently.

func (s Sink[T]) FillFrom(recv Receiver[T]) task.Task

type Source[T any] <-chan T

func NewSource[T any](c <-chan T) Source[T]

NewSource takes a readable channel and returns a Source, which can be used to chain common transformations fluently.

func (s Source[T]) ForwardTo(send Sender[T]) task.Task