streampb is a library heavily inspired from recordio. It frames messages
using a varint.
The underlying techniques used are as described in the official docs.
go get -u github.com/cyx/streampb
// encoding
enc := streampb.NewEncoder(w)
enc.Encode(ptypes.DurationProto(42 * time.Minute))
// decoding
var d duration.Duration
dec := streampub.NewDecoder(r)
dec.Decode(&d)Special thanks to @eclesh for the work on recordio.