go decode sample

decode.go

package main

import (
        "context"
        "encoding/base64"
        "io"
        "os"
        "strings"

        "golang.org/x/sync/errgroup"
)

const Message = "44GC44GE44GG44GI44GK"

// ただのデコード
/*
func main() {
        data, err := base64.StdEncoding.DecodeString(Message)
        if err != nil {
                panic(err)
        }

        fmt.Println(string(data))
}
 */

// デコードのpipe版
/*
func main()  {
        source := strings.NewReader(Message)
        decoder := base64.NewDecoder(base64.StdEncoding, source)
        pr, pw := io.Pipe()
        go func() {
                _, err := io.Copy(pw, decoder)
                if err != nil {
                        pw.CloseWithError(err)
                } else {
                        pw.Close()
                }
        }()

        io.Copy(os.Stdout, pr)
}
 */

// デコードのpipe版 error　group　利用
func main()  {
        source := strings.NewReader(Message)
        decoder := base64.NewDecoder(base64.StdEncoding, source)
        eg, _ := errgroup.WithContext(context.Background())
        pr, pw := io.Pipe()
        eg.Go(func() error {
                defer func() {
                        if err := pw.Close(); err != nil {
                                panic("PipeWriterを閉じれません")
                        }
                }()
                _, err := io.Copy(pw, decoder)
                if err != nil {
                        return err
                }
                return nil
        })

        io.Copy(os.Stdout, pr)

        if err := eg.Wait(); err != nil {
                panic(err)
        }
}