diff options
Diffstat (limited to 'plugins/http/channel.go')
| -rw-r--r-- | plugins/http/channel.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/plugins/http/channel.go b/plugins/http/channel.go index 42b73730..23b5ff3e 100644 --- a/plugins/http/channel.go +++ b/plugins/http/channel.go @@ -6,7 +6,7 @@ import ( // messages method used to read messages from the ws plugin with the auth requests for the topics and server func (p *Plugin) messages() { - for msg := range p.hub.ReceiveCh() { + for msg := range p.hub.ToWorker() { p.RLock() // msg here is the structure with http.ResponseWriter and http.Request rmsg := msg.(struct { @@ -14,9 +14,10 @@ func (p *Plugin) messages() { Req *http.Request }) + // invoke handler with redirected responsewriter and request p.handler.ServeHTTP(rmsg.RW, rmsg.Req) - p.hub.SendCh() <- struct { + p.hub.FromWorker() <- struct { RW http.ResponseWriter Req *http.Request }{ |