STOPMERGECLOSE OMIT NaiveDedupe converts a stream of Items that may contain duplicates into one that doesn't.

STARTNAIVEMERGE OMIT

New returns a new Registry interface

Prune removes nil entries from the registry

Register adds an item to the registry and returns an identifying string

Register allows an instance to register itself to listen/observe events.

RegisterName adds an item to the registry under the suppplied identifier and returns an identifying string Returns a NameAlreadyRegistered error if th

Release place a new resource into the pool. After a resource is acquired and no longer needed, it must be released back into the pool. This is where t

Run runs the given function, passing it a stopper channel. If the deadline passes before the function finishes executing, Run returns ErrTimeOut to th

Run submits work to the pool. This method is used to submit work into the pool. It accepts an interface value of type Worker and sends that value thro

Run runs a Task and does appropriate accounting via a given sync.WorkGroup.

https://medium.com/capital-one-developers/buffered-channels-in-go-what-are-they-good-for-43703871828 One common pattern for goroutines is fan-out. Whe

SayHi provides a mock function with given fields: