Channels implementation with new listeners - Githubissues

lampepfl / gears

A strawman for a low-level async library in Scala 3.

https://lampepfl.github.io/gears/

Apache License 2.0

257 stars 26 forks source link

Channels implementation with new listeners #23

Closed natsukagami closed 11 months ago

natsukagami commented 11 months ago

Depends on #21 and #22.

Channel stuff

New implementation for sync and bounded channels, based on lockBoth.
Remove suspendSupport requirement from channel.
New channel kind: unbounded channels, with .sendImmediately non-suspending.
ChannelMultiplexer changes a bit: there is now a blocking/suspending start() method instead of spawning a background working.

Stuff based on channels

Future Collectors: Seq[Future[T]] => ReadableChannel[Future[T]], with values arriving as they are completed.
Implement collector-based future collection extensions: Seq[Future[T]] has awaitAll(OrCancel) and altAll(WithCancel)

Other misc goodies

Add shorthand .await syntax to sources.
Add Source.values to quickly create a new source based on a list of values.