1 // Copyright 2013 Matt T. Proud
3 // Licensed under the Apache License, Version 2.0 (the "License");
4 // you may not use this file except in compliance with the License.
5 // You may obtain a copy of the License at
7 // http://www.apache.org/licenses/LICENSE-2.0
9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS,
11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 // See the License for the specific language governing permissions and
13 // limitations under the License.
21 "github.com/golang/protobuf/proto"
24 // WriteDelimited encodes and dumps a message to the provided writer prefixed
25 // with a 32-bit varint indicating the length of the encoded message, producing
26 // a length-delimited record stream, which can be used to chain together
27 // encoded messages of the same type together in a file. It returns the total
28 // number of bytes written and any applicable error. This is roughly
29 // equivalent to the companion Java API's MessageLite#writeDelimitedTo.
30 func WriteDelimited(w io.Writer, m proto.Message) (n int, err error) {
31 buffer, err := proto.Marshal(m)
36 var buf [binary.MaxVarintLen32]byte
37 encodedLength := binary.PutUvarint(buf[:], uint64(len(buffer)))
39 sync, err := w.Write(buf[:encodedLength])
44 n, err = w.Write(buffer)