func NewReader(mr MsgReader) *Reader {
	r := Reader{
		mr: mr,
	}
	return &r
}
NewReader creates a streaming reader from a MessageReader
package streamio
import (
	"crypto/md5"
	"encoding/base64"
	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/flogging"
)
var logger = flogging.MustGetLogger("view-sdk.apps.ipo")
type MsgReader interface {
	Read() ([]byte, error)
}
type Reader struct {
	mr  MsgReader
	buf []byte
}