func (s *Stream) NewReader() (io.Reader, error) {
	r, err := s.Open()

	if err != nil {
		return nil, err
	}

	return &streamReader{
		stream: s,
		reader: r,
	}, nil
}
// NewReader returns a new reader for the stream. May be called multiple times
// and each reader may read from the stream concurrently
NewReader returns a new reader for the stream. May be called multiple times
and each reader may read from the stream concurrently
// NewReader returns a new reader for the stream . May be called multiple times // and each reader may read from the stream concurrently
func (s *Stream) NewReader() (io.Reader, error) {
	r, err := s.Open()
	if err != nil {
		return nil, err
	}
	return &streamReader{
		stream: s,
		reader: r,
	}, nil
}
func ( s * Stream ) NewReader ( ) ( io . Reader , error ) { r , err := s . Open ( ) if err != nil { return nil , err } return & streamReader { stream : s , reader : r , } , nil }
NewReader returns a new reader for the stream.
NewReader returns a new reader for the stream .