Read and write protobuf messages over a duplex stream
This module makes it easy to send and receive length-prefixed Protobuf encoded messages over streams.
import { pbStream } from 'it-protobuf-stream'
import { MessageType } from './src/my-message-type.js'
// RequestType and ResponseType have been generate from `.proto` files and have
// `.encode` and `.decode` methods for serialization/deserialization
const stream = pbStream(duplex)
// write a message to the stream
stream.write({
foo: 'bar'
}, MessageType)
// read a message from the stream
const res = await stream.read(MessageType)
$ npm i it-protobuf-stream
<script>
tagLoading this module through a script tag will make its exports available as ItProtobufStream
in the global namespace.
<script src="https://unpkg.com/it-protobuf-stream/dist/index.min.js"></script>
Licensed under either of
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.
This module makes it easy to send and receive length-prefixed Protobuf encoded messages over streams.
Example