milarin e7c7fca697 added buffer argument to OfSeq and OfSeq2

2024-09-09 10:44:32 +02:00

chan_io.go

WriteIntoWriter handles error values

2023-03-25 11:52:57 +01:00

each.go

fixed naming schemes for Each methods

2023-03-04 11:24:42 +01:00

filter.go

more filter functions

2024-05-14 20:26:58 +02:00

find.go

fixed cancel call in FindFirstAndCancel

2024-01-10 22:00:20 +01:00

flat.go

FlatMap function introduced

2024-05-10 20:32:41 +02:00

forward.go

initial commit

2022-02-09 12:10:02 +01:00

go.mod

OfSeq and OfSeq2 introduced

2024-09-06 13:49:16 +02:00

group.go

initial commit

2022-02-09 12:10:02 +01:00

internal_stuff.go

- efficiency of toMap improved by concurrently calling the mapper function

2022-12-17 19:50:41 +01:00

limited_runner.go

fixed LimitedRunner behavior if runnable panics

2022-03-30 15:23:47 +02:00

map.go

fixed Map function to wait until all values were mapped before closing channel

2023-03-06 13:03:10 +01:00

merge.go

initial commit

2022-02-09 12:10:02 +01:00

of.go

added buffer argument to OfSeq and OfSeq2

2024-09-09 10:44:32 +02:00

result.go

refactored result wrapper func names

2024-04-04 19:13:43 +02:00

runner.go

initial commit

2022-02-09 12:10:02 +01:00

tee.go

fixed naming schemes for Each methods

2023-03-04 11:24:42 +01:00

timeout.go

various optimizations

2022-03-30 15:49:24 +02:00

to.go

ToSliceContinuous implemented

2023-04-14 19:05:27 +02:00

unlimited_runner.go

initial commit

2022-02-09 12:10:02 +01:00

utils.go

fixed naming schemes for Each methods

2023-03-04 11:24:42 +01:00

Description

Convenient functions for working with channels in Go

gomodule

85 KiB

Languages

Go 100%