| package gexec_test | 
 |  | 
 | import ( | 
 | 	"bytes" | 
 |  | 
 | 	. "github.com/onsi/gomega/gexec" | 
 |  | 
 | 	. "github.com/onsi/ginkgo" | 
 | 	. "github.com/onsi/gomega" | 
 | ) | 
 |  | 
 | var _ = Describe("PrefixedWriter", func() { | 
 | 	var buffer *bytes.Buffer | 
 | 	var writer *PrefixedWriter | 
 | 	BeforeEach(func() { | 
 | 		buffer = &bytes.Buffer{} | 
 | 		writer = NewPrefixedWriter("[p]", buffer) | 
 | 	}) | 
 |  | 
 | 	It("should emit the prefix on newlines", func() { | 
 | 		writer.Write([]byte("abc")) | 
 | 		writer.Write([]byte("def\n")) | 
 | 		writer.Write([]byte("hij\n")) | 
 | 		writer.Write([]byte("\n\n")) | 
 | 		writer.Write([]byte("klm\n\nnop")) | 
 | 		writer.Write([]byte("")) | 
 | 		writer.Write([]byte("qrs")) | 
 | 		writer.Write([]byte("\ntuv\nwx")) | 
 | 		writer.Write([]byte("yz\n\n")) | 
 |  | 
 | 		Ω(buffer.String()).Should(Equal(`[p]abcdef | 
 | [p]hij | 
 | [p] | 
 | [p] | 
 | [p]klm | 
 | [p] | 
 | [p]nopqrs | 
 | [p]tuv | 
 | [p]wxyz | 
 | [p] | 
 | `)) | 
 | 	}) | 
 | }) |