summaryrefslogtreecommitdiff
path: root/plugins/http/channel.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/http/channel.go')
-rw-r--r--plugins/http/channel.go29
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()
- }
-}