rdleal / go-async Goto Github PK

auto, _ := sync.Auth(context.Background(), async.FuncMap{...}, Option...)
result, _ := auto.Process("Argument)
``

type msg struct {
		Greet, Name string
	}

	fm := async.FuncMap{
		"reader":  strings.NewReader,
		"decoder": async.DependsOn("reader").To(utils.Json.NewDecoder),
		"parser": async.DependsOn("decoder").To(func(d *jsoniter.Decoder) (msg, error) {
			var m msg
			err := d.Decode(&m)
			return m, err
		}),
		"greet": async.DependsOn("parser").To(func(m msg) string {
			return strings.Title(m.Greet)
		}),
		"name": async.DependsOn("parser").To(func(m msg) string {
			return strings.Title(m.Name)
		}),
		"greeter": async.DependsOn("greet", "name").To(func(greet, name string) string {
			return fmt.Sprintf("%s, %s!", greet, name)
		}),
	}
	for i := 0; i < 100; i++ {
		go func(j int) {
			jsonStr := `{"greet": "hello", "name" : "gopher-` + strconv.Itoa(j) + `"}`
			start := time.Now()
			fnc, err := async.Auto(context.Background(), fm, async.WithArgs(jsonStr))
			if err != nil {
				log.Fatal(err)
			}

			for fn := range fnc {
				res, err := fn.Returned()
				if err != nil {
					log.Fatal(err)
				}
				fmt.Println(res[0]) // Hello, Gopher!
			}
			fmt.Println(fmt.Sprintf("%s", time.Since(start)))
		}(i)
	}