go/src/io/pipe_test.go

func checkWrite(t *testing.T, w Writer, data []byte, c chan int) { … }

// Test a single read/write pair.
func TestPipe1(t *testing.T) { … }

func reader(t *testing.T, r Reader, c chan int) { … }

// Test a sequence of read/write pairs.
func TestPipe2(t *testing.T) { … }

type pipeReturn …

// Test a large write that requires multiple reads to satisfy.
func writer(w WriteCloser, buf []byte, c chan pipeReturn) { … }

func TestPipe3(t *testing.T) { … }

type closer …

type pipeTest …

func (p pipeTest) String() string { … }

var pipeTests …

func delayClose(t *testing.T, cl closer, ch chan int, tt pipeTest) { … }

func TestPipeReadClose(t *testing.T) { … }

// Test close on Read side during Read.
func TestPipeReadClose2(t *testing.T) { … }

func TestPipeWriteClose(t *testing.T) { … }

// Test close on Write side during Write.
func TestPipeWriteClose2(t *testing.T) { … }

func TestWriteEmpty(t *testing.T) { … }

func TestWriteNil(t *testing.T) { … }

func TestWriteAfterWriterClose(t *testing.T) { … }

func TestPipeCloseError(t *testing.T) { … }

func TestPipeConcurrent(t *testing.T) { … }

func sortBytesInGroups(b []byte, n int) []byte { … }

var rSink …

var wSink …

func TestPipeAllocations(t *testing.T) { … }