diff options
Diffstat (limited to 'plugins/http/channel.go')
-rw-r--r-- | plugins/http/channel.go | 29 |
1 files changed, 0 insertions, 29 deletions
diff --git a/plugins/http/channel.go b/plugins/http/channel.go deleted file mode 100644 index 23b5ff3e..00000000 --- a/plugins/http/channel.go +++ /dev/null @@ -1,29 +0,0 @@ -package http - -import ( - "net/http" -) - -// 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.ToWorker() { - p.RLock() - // msg here is the structure with http.ResponseWriter and http.Request - rmsg := msg.(struct { - RW http.ResponseWriter - Req *http.Request - }) - - // invoke handler with redirected responsewriter and request - p.handler.ServeHTTP(rmsg.RW, rmsg.Req) - - p.hub.FromWorker() <- struct { - RW http.ResponseWriter - Req *http.Request - }{ - rmsg.RW, - rmsg.Req, - } - p.RUnlock() - } -} |