Golang stream gzip compression and decompression

main.go

package main

import (
  "compress/gzip"
  "io"
  "log"
  "os"
)

func main() {
  compressedReader, compressedWriter := io.Pipe()

  // Compressed data will be written to pipe.
  compressorWriter := gzip.NewWriter(compressedWriter)

  inputReader := os.Stdin

  go func() {
    // Initialize compression by draining input.
    if _, err := io.Copy(compressorWriter, inputReader); err != nil {
      log.Fatal(err)
    }

    // Ensure all data was flushed.
    if err := compressorWriter.Close(); err != nil {
      log.Fatal(err)
    }

    // Close writing to pipe, so reading from it does not block infinitely.
    if err := compressedWriter.Close(); err != nil {
      log.Fatal(err)
    }
  }()

  // Start decompressing using data from pipe.
  decompressorReader, err := gzip.NewReader(compressedReader)
  if err != nil {
    log.Fatal(err)
  }

  outputWriter := os.Stdout

  // Finally, copy output into stdout.
  if _, err := io.Copy(outputWriter, decompressorReader); err != nil {
    log.Fatal(err)
  }
}