diff options
| author |  Aliaksandr Valialkin <valyala@gmail.com>
| 2015-11-11 16:17:12 +0200 |
|---|---|---|
| committer | Aliaksandr Valialkin <valyala@gmail.com>
| 2015-11-11 16:17:12 +0200 |
| commit | 69758b81d69c26b2cafbf4741291e1b50b82c3fc (patch) | |
| tree | 3d12ba84ed47a35c7b8de50bf3fb3601eb0a0a55 /workerpool.go | |
| parent | Extracted workerPool from server.go into workerpool.go (diff) | |
| download | fasthttp-69758b81d69c26b2cafbf4741291e1b50b82c3fc.tar.gz fasthttp-69758b81d69c26b2cafbf4741291e1b50b82c3fc.tar.bz2 fasthttp-69758b81d69c26b2cafbf4741291e1b50b82c3fc.zip | |
Accept net.Conn instead of io.ReadWriteCloser in Serve*() methods, since in reality we use net.Conn methods such as RemoteAddr, SetReadDeadline and SetWriteDeadline
Diffstat (limited to 'workerpool.go')
| -rw-r--r-- | workerpool.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/workerpool.go b/workerpool.go index fe5cf56..c472c58 100644 --- a/workerpool.go +++ b/workerpool.go @@ -1,7 +1,6 @@ package fasthttp import ( - "io" "net" "runtime/debug" "sync" @@ -14,7 +13,7 @@ import ( type workerPool struct { // Function for serving incoming connections. // It must close c before returning. - WorkerFunc func(c io.ReadWriteCloser) error + WorkerFunc func(c net.Conn) error // Maximum number of workers to create. MaxWorkersCount int |