rubaxa / flow Goto Github PK

import "github.com/rubaxa/flow"

res := flow.Defer(3, func (ret flow.Stream) {
    ret <- "1"
    ret <- "2"
    ret <- "3"
});

fmt.Println("Result:", <-res)

res := flow.Defer(func (ret flow.Stream) {
    ret <- "logic"
});

fmt.Println("Result:", <-res)

func main() {
    input := getInputChan();

    // Читаем канал в 15 потоков
    wg := flow.CreateWorkerPool(15, func () {
        for raw := range input {
            // Чтение канала
        }
    })

    wg.Wait()
}

    err := flow.Go(
        func() (err error) {
            // Первая задача
            return;
        },

        func() (err error) {
            // Вторая задача
            return;
        },
    )