Go Meetup NYC; 29th Jan

wrapper.go

package main

import (
	"io"
	"os"
	"fmt"
	"time"
)

type SlowWriter struct {
	w  io.Writer
	bps int
}

func (s *SlowWriter) Write(p []byte) (n int, err error) {
	bytesPerSecond := s.bps/8

	finalN := 0
	fmt.Println(bytesPerSecond)

	for i := 0; i < len(p); i+= bytesPerSecond {
		n, err := s.w.Write(p[i:i + bytesPerSecond])
		finalN = finalN + n
		if err != nil {
			return finalN, err
		}
		time.Sleep(time.Second)
	}

	return finalN, nil
}


func main() {
	data := []byte("random data")
	s := SlowWriter{w: os.Stdout, bps: 8}
	s.Write(data)
}