src/client/pkg/grpcutil/stream.go
func NewStreamingBytesReader(streamingBytesClient StreamingBytesClient, cancel context.CancelFunc) io.ReadCloser {
	return &streamingBytesReader{streamingBytesClient: streamingBytesClient, cancel: cancel}
}
func NewStreamingBytesReader(streamingBytesClient StreamingBytesClient, cancel context.CancelFunc) io.ReadCloser {
	return &streamingBytesReader{streamingBytesClient: streamingBytesClient, cancel: cancel}
}
func NewStreamingBytesReader ( streamingBytesClient StreamingBytesClient , cancel context . CancelFunc ) io . ReadCloser { return & streamingBytesReader { streamingBytesClient : streamingBytesClient , cancel : cancel } }
// NewStreamingBytesReader returns an io.Reader for a StreamingBytesClient.
NewStreamingBytesReader returns an io . Reader for a StreamingBytesClient .