zbytes

zbytes/zbytes.go

+package zbytes
+
+import (
+	"bytes"
+	"sync"
+)
+
+type ZBuffer struct {
+	Buff *bytes.Buffer
+	Mu   *sync.Mutex
+}
+
+func NewBuffer() *ZBuffer {
+	return &ZBuffer{
+		Buff: bytes.NewBuffer(nil),
+		Mu:   new(sync.Mutex),
+	}
+}
+
+func (z *ZBuffer) Write(p []byte) (n int, err error) {
+	z.Mu.Lock()
+	defer z.Mu.Unlock()
+	return z.Buff.Write(p)
+}
+func (z *ZBuffer) WriteRune(r rune) (n int, err error) {
+	z.Mu.Lock()
+	defer z.Mu.Unlock()
+	return z.Buff.WriteRune(r)
+}
+func (z *ZBuffer) WriteByte(c byte) error {
+	z.Mu.Lock()
+	z.Mu.Unlock()
+	return z.Buff.WriteByte(c)
+}
+func (z *ZBuffer) WriteString(s string) (n int, err error) {
+	z.Mu.Lock()
+	defer z.Mu.Unlock()
+	return z.Buff.WriteString(s)
+}
+
+func (z *ZBuffer) Bytes() []byte {
+	z.Mu.Lock()
+	defer z.Mu.Unlock()
+	return z.Buff.Bytes()
+}
+
+func (z *ZBuffer) String() string {
+	z.Mu.Lock()
+	defer z.Mu.Unlock()
+	return z.Buff.String()
+}
+
+func (z *ZBuffer) Reset() {
+	z.Mu.Lock()
+	defer z.Mu.Unlock()
+	z.Buff.Reset()
+}
+func (z *ZBuffer) Len() int {
+	z.Mu.Lock()
+	defer z.Mu.Unlock()
+	return z.Buff.Len()
+}