Function NewPipeBomb

api/cloudcontroller/pipebomb.go:24–27

NewPipeBomb returns an io.WriteCloser that can be used to stream data to a the Pipebomb.

()

// NewPipeBomb returns an io.WriteCloser that can be used to stream data to a
// the Pipebomb.
func NewPipeBomb() (*Pipebomb, io.WriteCloser) {
	writerOutput, writerInput := io.Pipe()
	return &Pipebomb{ReadCloser: writerOutput}, writerInput
}