|  | 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] | 
|  | `)) | 
|  | }) | 
|  | }) |