Rsocket Py Versions Save

• Breaking change: Normalized the request_channel method argument names across implementations and added where missing (vanilla, reactivex etc.):
  • local_publisher renamed to publisher
  • sending_done_event renamed to sending_done
• Breaking change: ReactiveX clients will remove empty payload from request_response Observable, resulting in an actually empty Observable
• Bug fix: fixed channel stream being released prematurely when canceled by requester, and responder side still working
• Bug fix: removed cyclic references in RSocketBase which caused old sessions not to be released
• Bug fix: fixed ability for ReactiveX streams and fragmented responses to send payloads concurrently
• CollectorSubscriber : exposed subscription methods directly instead of relying on internal subscription variable
• Reactivex server side request_response allowed to return reactivex.empty(). Library code will replace with empty Payload when needed
• Added EmptyStream for use in stream and channel responses
• Tutorial code: release logged out users from global chat data (weak references)

• Fragmentation fix - empty payload (either in request or response) with fragmentation enabled failed to send
• Breaking change: on_connection_lost was renamed to on_close. An on_connection_error method was added to handle initial connection errors
• Routing request handler:
  • Throws an RSocketUnknownRoute exception which results in an error frame on the requester side
  • Added error logging for response/stream/channel requests
• Added create_response helper method as shorthand for creating a future with a Payload
• Added utf8_decode helper. Decodes bytes to utf-8. If data is None, returns None.
• Refactoring client reconnect flow
• Added example code for tutorial on rsocket.io

• Command line fixes:
  • limit_rate argument was effectively ignored. fixed
• Added on_ready callback to RSocketServer. Called when sender/receiver tasks are ready
• Implement ReactiveX (3.0, 4.0) server side handler. Allows to define RequestHandler directly using ReactiveX
• Added sending_done_event argument to request_channel to allow client to wait until sending to server is complete/canceled
• Added find_by_mimetype to CompositeMetadata class. Returns list of relevant items by mimetype
• Breaking Change: Removed RSocketBase class dependency from RequestHandler. It is not longer required as an argument to init

• Command line fixes:
  • Support passing ssl certificate and http headers when using ws/wss
  • Support requesting --version without the need to specify URI arguments
  • Option --interactionModel to specify interaction (eg. request_response, request_stream)
  • Added Metadata Push support

• Added running tests on python 3.11 and package classification
• Removed data and metadata content from logs. Replaced with data and metadata sizes
• Performance test examples available in performance folder
• WSS (Secure websocket) example and support (aiohttp)
  • Refactored Websocket transport to allow providing either url or an existing websocket
• Added command line tool (rsocket-py)

changes from 0.4:

• Added running tests on python 3.11 and package classification
• Removed data and metadata content from logs. Replaced with data and metadata sizes
• Performance test examples available in performance folder
• WSS (Secure websocket) example and support (aiohttp)
  • Refactored Websocket transport to allow providing either url or an existing websocket
• Added command line tool (rsocket-py)

Changes from 0.3:

• Breaking change: Added ability to await fire_and_forget and push_metadata:
  • Both now return a future which resolves when the payload was sent completely (including fragmentation for fnf)
• Fixed fragmentation implementation (misunderstood spec):
  • fragments after first one are now correctly of type PayloadFrame
  • fragment size now includes frame header and length
  • Added checking fragment size limit (minimum 64) as in java implementation
  • Updated examples
• Added reactivex (RxPy version 4) wrapper client
• Added Initial support for http3 (wss)
• Better type hint for return value of request_response

• Breaking change: Added ability to await fire_and_forget and push_metadata:
  • Both now return a future which resolves when the frame (or all fragments) finished sending.
• Fixed fragmentation implementation (misunderstood spec):
  • fragments after first one are now correctly of type PayloadFrame
  • fragment size now includes frame header and length.
  • Added checking fragment size limit (minimum 64) as in java implementation
  • Updated examples
• Added reactivex (RxPy version 4) wrapper client

Release stable version.

Implemented most of the RSocket protocol (no resume support).

Support for:

• Protocols: TCP, Websocket, QUIC
• RxPy pipes
• Reconnection

What's Changed

• Basic QUIC support (aioquic)
• Fixed reconnect flow and added tests for all transports