)]}' { "commit": "299b803aaee9a0dc0b2ec8c81fac66341045b8b2", "tree": "61d511d1938a28ce3e51d17417ddb37b4f9c6cf2", "parents": [ "758a88d5994942bb70eafbb08949cc58462b9924" ], "author": { "name": "tmdiep", "email": "tmdiep@google.com", "time": "Thu Nov 19 12:13:51 2020 +1100" }, "committer": { "name": "GitHub", "email": "noreply@github.com", "time": "Thu Nov 19 12:13:51 2020 +1100" }, "message": "feat(pubsublite): Single and multi partition subscribers (#3221)\n\nImplements:\r\n- subscriberStream: directly wraps the Subscribe bidi stream\r\n- singlePartitionSubscriber: wraps the committer and subscriberStream\r\n- multiPartitionSubscriber: receives messages from multiple fixed partitions", "tree_diff": [ { "type": "modify", "old_id": "785cdd097bb5c29f07d90886165b408b22ed8876", "old_mode": 33188, "old_path": "pubsublite/internal/wire/flow_control.go", "new_id": "3ac3a848bd041295ad3b250d65979e6c92d76fe3", "new_mode": 33188, "new_path": "pubsublite/internal/wire/flow_control.go" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "9aee40b072212d2800b7e3f9bcf08939a9d89500", "new_mode": 33188, "new_path": "pubsublite/internal/wire/subscriber.go" }, { "type": "add", "old_id": "0000000000000000000000000000000000000000", "old_mode": 0, "old_path": "/dev/null", "new_id": "385c971543dc8299e5649e15d7db88929cab57c5", "new_mode": 33188, "new_path": "pubsublite/internal/wire/subscriber_test.go" } ] }