v11.0.0-pre1

Pre-release of v11.
v11 is a re-design of fuego that takes advantage of Go 1.18's type parameter feature.
This is a substantial change to fuego.

Changes around ToEntryMap

Removed EntryMap.Append*
Added EntryMap.Merge

go.dev doc link

v9.0.3

README go.dev doc link

go.mod v9 fix

v9.0.2

Go mod v9

Update README links

Merge pull request #15 from seborama/README_Update

Readme update

Add Collector.ToEntryMap + go.mod

Merge pull request #14 from seborama/Collectors_ToEntryMap

Add collectors.ToEntryMap

New orderly concurrency model (FlatMap)

This release implements the new orderly concurrency model to Stream.FlatMap.

Example:

NewStream(someChannel).Concurrent(300).FlatMap(someStreamFunction)

or indeed:

NewConcurrentStream(someChannel, 300).FlatMap(someStreamFunction)

Minor internal formalisation of new orderly concurrency

Merge pull request #11 from seborama/preserve_concurrency_with_return…

…_streams

Preserve concurrency with return streams

New orderly concurrency model (Map)

This release implements a new orderly concurrency model, presently available on Stream.Map only.

Example:

NewStream(someChannel).Concurrent(300).Map(someFunction)

TupleN.MapMulti

Adds TupleN.MapMulti()