p25734189
/
wheat-cache
forked from p93542168/wheat-cache
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

feat(middle): add middle worker function

This commit is contained in:
Sodesnei 2021-10-09 17:50:54 +08:00
parent 79bef5ba72
commit dca19238da
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/middle/worker.go
View File

@ -11,6 +11,7 @@ func (m *MiddleWare) middleWorker() {
for _, singles := range m.plugins { for _, singles := range m.plugins {
for _, single := range singles { for _, single := range singles {
single.Exec(workEvent) single.Exec(workEvent)
} }
} }

1
pkg/middle/worker_test.go
View File

@ -8,6 +8,7 @@ import (
func TestWorker(t *testing.T) { func TestWorker(t *testing.T) {
event := event.NewEvent("LogContext") event := event.NewEvent("LogContext")
m := NewMiddleWare() m := NewMiddleWare()
m.eventDriver.Put(event) m.eventDriver.Put(event)