workers

README

This is a package that allows multiple goroutines doing the same task to deduplicate their work: the task gets executed once with all subscribers getting the shared result back.

Documentation

Index

• type Worker
  • func New() Worker

Types

type Worker

type Worker interface {
	Run(id string, fn func() interface{}) (<-chan interface{}, bool)
}

func New

func New() Worker