syncreader

README

syncreader

SyncReader creates a reader that its reads to synchronize with first reader, similar to the io.MultiWriter .

View the docs.

APIs

New(readers ...io.Reader)

First reader is source reader, other readers read to synchronize whith first reader. If first readera retures EOF, other readers also return.

Usage

Reading a file in progress.

import "github.com/go-libs/syncreader"
import "github.com/go-libs/progress"

filename := "syncreader_test.go"
f, err := os.Open(filename)
defer f.Close()
if err != nil {
  log.Fatalln(err)
}

fs, err := os.Stat(filename)
if err != nil {
  log.Fatalln(err)
}

p := progress.New()
p.Total = fs.Size()
p.Progress = func(c, t, e int64) {
  log.Println(c, t, e)
}
b := new(bytes.Buffer)
r := syncreader.New(f, p)
_, err = b.ReadFrom(r)
if err != nil {
  log.Fatalln(err)
}

View the docs.

Documentation

Index

• func New(readers ...io.Reader) io.Reader
• type SyncReader
  • func (sr *SyncReader) Read(p []byte) (n int, err error)

Functions

func New

func New(readers ...io.Reader) io.Reader

Types

type SyncReader

type SyncReader struct {
	// contains filtered or unexported fields
}

func (*SyncReader) Read

func (sr *SyncReader) Read(p []byte) (n int, err error)