From 489bc792e16d86dd9819c5915a29afd8902ce538 Mon Sep 17 00:00:00 2001 From: a Date: Sat, 26 Mar 2022 21:42:22 -0500 Subject: [PATCH] add task --- examples/generic_pr/main.go | 60 --------------------------- examples/http_request_example/main.go | 30 ++++++++++++++ examples/parallel_request/main.go | 43 ------------------- task/http_request.go | 55 ++++++++++++++++++++++++ 4 files changed, 85 insertions(+), 103 deletions(-) delete mode 100644 examples/generic_pr/main.go create mode 100644 examples/http_request_example/main.go delete mode 100644 examples/parallel_request/main.go create mode 100644 task/http_request.go diff --git a/examples/generic_pr/main.go b/examples/generic_pr/main.go deleted file mode 100644 index cb0246a..0000000 --- a/examples/generic_pr/main.go +++ /dev/null @@ -1,60 +0,0 @@ -package main - -import ( - "encoding/json" - "fmt" - "log" - "net/http" - - "git.tuxpa.in/a/lambda" - "git.tuxpa.in/a/lambda/parallel" -) - -type RequestContext[T any] struct { - req http.Request - ans T - err error -} - -func (r *RequestContext[T]) String() string { - return fmt.Sprintf("%+v", r.ans) -} - -func (_ *RequestContext[T]) Do() func(r *RequestContext[T]) *RequestContext[T] { - return func(r *RequestContext[T]) *RequestContext[T] { - r.ans = *new(T) - res, err := http.DefaultClient.Do(&r.req) - if err != nil { - r.err = err - return r - } - defer res.Body.Close() - r.err = json.NewDecoder(res.Body).Decode(&r.ans) - return r - } -} - -func (_ *RequestContext[T]) FilterErr() func(r *RequestContext[T]) bool { - return func(r *RequestContext[T]) bool { - return r.err == nil - } -} - -type someResult struct { - Title string `json:"title"` - Id int `json:"id"` -} - -func main() { - var requests = make([]*RequestContext[someResult], 20) - for i := range requests { - r, _ := http.NewRequest("GET", fmt.Sprintf("https://jsonplaceholder.typicode.com/todos/%d", i+1), nil) - requests[i] = &RequestContext[someResult]{ - req: *r, - } - } - results := lambda.Filter(parallel.Map(requests, requests[0].Do(), 4), requests[0].FilterErr()) - for _, v := range results { - log.Printf("%s", v) - } -} diff --git a/examples/http_request_example/main.go b/examples/http_request_example/main.go new file mode 100644 index 0000000..798655f --- /dev/null +++ b/examples/http_request_example/main.go @@ -0,0 +1,30 @@ +package main + +import ( + "fmt" + "log" + "net/http" + + "git.tuxpa.in/a/lambda" + "git.tuxpa.in/a/lambda/parallel" + "git.tuxpa.in/a/lambda/task" +) + +type someResult struct { + Title string `json:"title"` + Id int `json:"id"` +} + +func main() { + var requests = make([]*task.HttpRequest[someResult], 20) + for i := range requests { + r, _ := http.NewRequest("GET", fmt.Sprintf("https://jsonplaceholder.typicode.com/todos/%d", i+1), nil) + requests[i] = &task.HttpRequest[someResult]{ + Req: *r, + } + } + results := lambda.Filter(parallel.Map(requests, requests[0].Json(), 4), requests[0].NoErr()) + for _, v := range results { + log.Printf("%s", v) + } +} diff --git a/examples/parallel_request/main.go b/examples/parallel_request/main.go deleted file mode 100644 index d7bbff4..0000000 --- a/examples/parallel_request/main.go +++ /dev/null @@ -1,43 +0,0 @@ -package main - -import ( - "encoding/json" - "fmt" - "log" - "net/http" - - "git.tuxpa.in/a/lambda/parallel" -) - -type someResult struct { - Title string `json:"title"` - Id int `json:"id"` -} - -func main() { - var requests = make([]*http.Request, 20) - - for i := range requests { - r, _ := http.NewRequest("GET", fmt.Sprintf("https://jsonplaceholder.typicode.com/todos/%d", i), nil) - requests[i] = r - } - - results, errs := parallel.MapErrorV(requests, func(r *http.Request) (*someResult, error) { - out := &someResult{} - res, err := http.DefaultClient.Do(r) - if err != nil { - return nil, err - } - defer res.Body.Close() - err = json.NewDecoder(res.Body).Decode(out) - return out, err - }, 4) - - for i, v := range results { - if errs[i] != nil { - log.Printf("err: %s", errs[i]) - } else { - log.Printf("result: %+v", v) - } - } -} diff --git a/task/http_request.go b/task/http_request.go new file mode 100644 index 0000000..8eb1930 --- /dev/null +++ b/task/http_request.go @@ -0,0 +1,55 @@ +package task + +import ( + "encoding/json" + "fmt" + "io" + "net/http" +) + +type DecoderFunc func(r io.Reader) Decoder + +type Decoder interface { + Decode(any) error +} + +type HttpRequest[T any] struct { + Req http.Request + ans T + err error +} + +func (r *HttpRequest[T]) String() string { + return fmt.Sprintf("%+v", r.ans) +} + +func (_ *HttpRequest[T]) With(df DecoderFunc) func(r *HttpRequest[T]) *HttpRequest[T] { + return func(r *HttpRequest[T]) *HttpRequest[T] { + r.ans = *new(T) + res, err := http.DefaultClient.Do(&r.Req) + if err != nil { + r.err = err + return r + } + defer res.Body.Close() + r.err = df(res.Body).Decode(&r.ans) + return r + } +} + +func (z *HttpRequest[T]) Json() func(r *HttpRequest[T]) *HttpRequest[T] { + return z.With(func(r io.Reader) Decoder { + return json.NewDecoder(r) + }) +} + +func (_ *HttpRequest[T]) NoErr() func(r *HttpRequest[T]) bool { + return func(r *HttpRequest[T]) bool { + return r.err == nil + } +} + +type someResult struct { + Title string `json:"title"` + Id int `json:"id"` +}