A subscriptions transport coalescer

[steveluscher]

Summary

Given two identical subscriptions, we should not send the request to the server twice. This higher-order transport watches for identical subscriptions over the same transport and returns the same DataPublisher to both.

Note

It is true that the server coalesces subscriptions on the backend, but coalescing them on the client is still worthwhile in that it reduces chatter over the wire (ie. the subsequent subscription requests don't even get made) and speeds up subscription time on the client for identical subscriptions.

[changeset-bot]

⚠️ No Changeset found

Latest commit: f77f8a0

Merging this PR will not cause a version bump for any packages. If these changes should not result in a new version, you're good to go. If these changes should result in a version bump, you need to add a changeset.

Click here to learn what changesets are, and how to add one.

Click here if you're a maintainer who wants to add a changeset to this PR

[steveluscher]

Warning

This pull request is not mergeable via GitHub because a downstack PR is open. Once all requirements are satisfied, merge this PR as a stack on Graphite.
Learn more

• A subscriptions transport coalescer #3316 👈
• Convert the websocket transport to a channel #3314
• Fix lint in version header #3315
• A channel augmenter that autopings the channel #3313
• A subscription plan that implements the Solana JSON WebSocket subscription API #3312
• A channel message demultiplexer #3311
• A channel pool #3310
• A channel augmenter that encodes and decodes messages as JSON #3309
• Revert ‘no argument’ conditional type from #3301 #3326
• master

This stack of pull requests is managed by Graphite. Learn more about stacking.

Join @steveluscher and the rest of your teammates on Graphite