The GitHub Actions job "CI" on pekko-connectors.git/pubsub-grpc-eager-pull-and-subscriber has succeeded. Run started by GitHub user hanishi (triggered by hanishi).
Head commit for run: 5929a649a659d597fc54eb32ce5663d3071d65e8 / hanishi <[email protected]> Google Cloud Pub/Sub gRPC: eager-pull stages, subscribe field-leak fix, and Subscriber resource * Bug 1: autoExtendAckDeadlines now tracks on receipt via EagerPullTrackingStage, not on push downstream. Prevents deadline expiry on messages buffered behind saturated mapAsync. * Bug 2: subsequent StreamingPullRequests built from defaultInstance, clearing clientId / maxOutstandingMessages / maxOutstandingBytes that the server rejects on non-initial requests. * Bug 3: FlowControlGateStage rewritten with the eager-pull pattern so permits are acquired on receipt; outstandingCount now reflects actual delivery. Pre-sized internal ArrayDeque to FlowControl.maxOutstandingMessages (clamped to 65536) to skip resize doublings during initial fill. * AckDeadlineExtender: caller-owned tracking map and ticker that survive RestartSource re-materializations (matches Google MessageDispatcher lifecycle). * Subscriber resource (GooglePubSub.subscriber): bundles subscribe + restart + autoExtend + optional flowControl with correct composition by construction. * ExampleApp.subscribeAutoExtend uses the new Subscriber API. Report URL: https://github.com/apache/pekko-connectors/actions/runs/25652098141 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
