Skip to content

Make reactive subscription request with Long.MAX_VALUE unbounded #1003

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Sep 9, 2021

Conversation

injectives
Copy link
Contributor

This update ensures that unbounded reactive request is translated to unbounded Bolt request.

This update ensures that unbounded reactive request is translated to unbounded Bolt request.
Copy link
Contributor

@michael-simons michael-simons left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Fine as of

A Subscription MUST support an unbounded number of calls to request and MUST support a demand up to 2^63-1 (java.lang.Long.MAX_VALUE). A demand equal or greater than 2^63-1 (java.lang.Long.MAX_VALUE) MAY be considered by the Publisher as “effectively unbounded”.

See: https://github.com/reactive-streams/reactive-streams-jvm/blob/v1.0.3/README.md#3-subscription-code

@injectives injectives merged commit e22c944 into neo4j:4.4 Sep 9, 2021
@injectives injectives deleted the feature/unboundedfetch branch September 9, 2021 13:22
injectives added a commit to injectives/neo4j-java-driver that referenced this pull request Sep 13, 2021
…4j#1003)

* Make reactive subscription request with Long.MAX_VALUE unbounded

This update ensures that unbounded reactive request is translated to unbounded Bolt request.

* Update ListBasedPullHandler test class to support unbounded request
injectives added a commit that referenced this pull request Sep 13, 2021
…update testkit backend (#1007)

* Add holder objects for driver, session, transaction and result objects in backend (#1001)

This update also removes hardcoded fetch size in reactive backend and adds support for sending additional PULL requests when there is more data to consume.

* Enable tests with custom fetch size in reactive backend (#1002)

Excluding negative fetch size values.

* Make reactive subscription request with Long.MAX_VALUE unbounded (#1003)

* Make reactive subscription request with Long.MAX_VALUE unbounded

This update ensures that unbounded reactive request is translated to unbounded Bolt request.

* Update ListBasedPullHandler test class to support unbounded request

* Enable unexpected interruption routing Testkit tests for reactive backend (#1004)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants