tree 61d511d1938a28ce3e51d17417ddb37b4f9c6cf2
parent 758a88d5994942bb70eafbb08949cc58462b9924
author tmdiep <tmdiep@google.com> 1605748431 +1100
committer GitHub <noreply@github.com> 1605748431 +1100
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJftcbPCRBK7hj4Ov3rIwAAdHIIAC+QBXYrNVPbRTfYiFbuDW/d
 gXzHcsabqUkO+kiOmIDeVL2cwgXPr9FTaYrUvzGZzuCBggpliOln+0HaBi7QziAg
 m5zqIbUXpIqNEzWT8ElOI2nAjPhFqbGzvhHebbZGl1QdxNhGYsCBBlS7dCCekdxu
 0b2ScxiKyprfI+Rl6WYre6Z7BX9qUtRNIprR+gXP4f78nbG7ytJqYxXf16TpQw+R
 s72gFMKtobfFNRHupxfCkYmLFCne80la5P/cUjC8H5x4LfMym5sLAnhJASJAQono
 mMhH4UA3S4dJltpe25q+qA1X9xIQrojyd97R/2WTnpMFW/2Ti3FcV3RlhmxTYVA=
 =QmVF
 -----END PGP SIGNATURE-----
 

feat(pubsublite): Single and multi partition subscribers (#3221)

Implements:
- subscriberStream: directly wraps the Subscribe bidi stream
- singlePartitionSubscriber: wraps the committer and subscriberStream
- multiPartitionSubscriber: receives messages from multiple fixed partitions