Method CloseWrite

stream/stream_test.go:109–115

()

}

func (m *mockedStream) CloseWrite() error {
	m.writeCloseOnce.Do(func() {
		close(m.writeCh)
	})

	return nil
}

func (m *mockedStream) closeReader() {
	close(m.readCh)