GumpacG opened a new pull request, #3396:
URL: https://github.com/apache/tinkerpop/pull/3396
Adds streaming GraphBinary deserialization to the Python driver. Results are
now deserialized directly from the HTTP response stream and pushed to the
ResultSet individually, rather than buffering the entire response before
processing.
Changes:
- Added AiohttpSyncStream wrapper and get_stream() to transport, replacing
read()
- Rewrote Connection._receive() to stream GB objects one-at-a-time via
GraphBinaryReader.to_object()
- Updated ResultSet.one()/all() for individual item queue entries; added
_EXHAUSTED sentinel to handle None as a valid Gremlin result
- Added content-type check before GB deserialization for non-GB error
responses
- Removed dead code: buffered read(), data_received_aggregate,
deserialize_message/read_payload, stream_chunk, max_content_length
- Removed GraphSON parameterized test fixtures
- Updated AbstractBaseTransport: read() → get_stream()
- 44 new unit tests covering streaming, bulking, error handling,
content-type checks, and incremental delivery timing
- Updated CHANGELOG and upgrade docs
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
