re
/
ants
forked from mirror/ants
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Integrating with http-server

This commit is contained in:
Andy Pan 2018-12-03 10:14:04 +08:00
parent c327085892 0562353fd9
commit 5bbeede097
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
README.md
View File

@ -119,7 +119,7 @@ type Request struct {
func main() {
pool, _ := ants.NewPoolWithFunc(100, func(payload interface{}) {
request, ok := payload.(Request)
request, ok := payload.(*Request)
if !ok {
request = Request{Param:[]byte(""), Result: make(chan []byte)}
}
@ -141,7 +141,7 @@ func main() {
}
defer r.Body.Close()
request := Request{Param: param, Result: make(chan []byte)}
request := &Request{Param: param, Result: make(chan []byte)}
// Throttle the requests with ants pool. This process is asynchronous and
// you can receive a result from the channel defined outside.

4
README_ZH.md
View File

@ -118,7 +118,7 @@ type Request struct {
func main() {
pool, _ := ants.NewPoolWithFunc(100, func(payload interface{}) {
request, ok := payload.(Request)
request, ok := payload.(*Request)
if !ok {
request = Request{Param:[]byte(""), Result: make(chan []byte)}
}
@ -140,7 +140,7 @@ func main() {
}
defer r.Body.Close()
request := Request{Param: param, Result: make(chan []byte)}
request := &Request{Param: param, Result: make(chan []byte)}
// Throttle the requests with ants pool. This process is asynchronous and
// you can receive a result from the channel defined outside.