package linewriter

import "gvisor.dev/gvisor/pkg/linewriter"

Package linewriter provides an io.Writer which calls an emitter on each line.

Index ¶

• type Writer
• func NewWriter(emitter func(p []byte)) *Writer
• func (w *Writer) Write(p []byte) (int, error)

Types ¶

type Writer ¶

type Writer struct {
	// the mutex locks buf.
	sync.Mutex
	// contains filtered or unexported fields
}

Writer is an io.Writer which buffers input, flushing individual lines through an emitter function.

func NewWriter ¶

func NewWriter(emitter func(p []byte)) *Writer

NewWriter creates a Writer which emits using emitter. The emitter must not retain p. It may change after emitter returns.

func (*Writer) Write ¶

func (w *Writer) Write(p []byte) (int, error)

Write implements io.Writer.Write. It calls emit on each line of input, not including the newline. Write may be called concurrently.

Source Files ¶

linewriter.go