aboutsummaryrefslogtreecommitdiffstats
path: root/ethreact/reactor.go
Commit message (Collapse)AuthorAgeFilesLines
* ethreact/README.mdzelig2014-07-211-1/+1
|
* fix reactor channel blockingzelig2014-07-151-26/+27
|
* remove extra case in main loopzelig2014-07-071-1/+1
|
* fix reactor engine main loop blocked to wait if drainedzelig2014-07-061-8/+14
|
* ethreactzelig2014-07-051-0/+175
- consistent renaming - React -> Event - ReactorEvent -> EventHandler - NewReactorEngine -> New - async ReactorEngine main loop with select on main eventChannel and quit channel - ReactorEngine main loop control with Start() Stop() Flush() - ReactorEngine.dispatch - use sync.RWMutex - delete eventHandler if subscribed channels go to 0