eapache/channels

SharedBuffer

Closed this issue · 0 comments

A struct implementing the Buffer interface with an additional method to spawn Channels. All channels spawned from a SharedBuffer will share the buffer space, so if one channel fills it up all others will block writing until space is available.

The SharedBuffer struct will have to own the goroutine, which will need to use reflection for dynamic select calls.