Merge branch 'master' into channels

# Conflicts:
#	CHANGELOG.rst
#	README.md
#	requirements.txt

Author: jell-o-fishi

.github/workflows/python-package.yml

@@ -16,7 +16,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12"]
+        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12", "3.13"]
     steps:
     - uses: actions/checkout@v2
     - name: Set up Python ${{ matrix.python-version }}
@@ -37,10 +37,11 @@ jobs:
       run: |
         pytest -n 1 --reruns 5 --cov-report=html --cov --ignore=examples tests
     - name: Archive code coverage html report
-      uses: actions/upload-artifact@v2
+      uses: actions/upload-artifact@v4
       with:
         name: code-coverage-report
         path: coverage_report_html
+        overwrite: true
     - name: Publish coveralls
       continue-on-error: true
       env:

.gitignore

@@ -91,3 +91,4 @@ ENV/
 # PyCharm
 *.iml
 .idea/
+python311/

.junie/guidelines.md

@@ -0,0 +1,88 @@
+
+# RSocket-py Project Analysis
+
+## Overview
+RSocket-py is a Python implementation of the [RSocket](http://rsocket.io) protocol, which is a binary protocol for use on byte stream transports such as TCP, WebSockets, and Aeron. The project provides a comprehensive implementation of the RSocket protocol with support for various transports, extensions, and integrations.
+
+## Key Components
+
+### Core Architecture
+- **RSocketBase**: The foundational class implementing the RSocket protocol, handling frame processing, stream management, and connection lifecycle.
+- **Transport Layer**: Supports multiple transports including TCP, WebSocket (via aiohttp, fastapi, quart, websockets), and QUIC.
+- **Request Handlers**: Implements the different interaction models (request-response, fire-and-forget, request-stream, request-channel).
+- **ReactiveX Integration**: Provides integration with ReactiveX (both v3 and v4) for reactive programming support.
+
+### Interaction Models
+- **Request-Response**: Simple request with a single response.
+- **Fire-and-Forget**: One-way message with no response.
+- **Request-Stream**: Request that receives a stream of responses.
+- **Request-Channel**: Bi-directional stream of messages.
+- **Metadata Push**: Metadata-only message with no response.
+
+### Extensions
+- **Composite Metadata**: Support for multiple metadata entries in a single payload.
+- **Routing**: Request routing capabilities similar to HTTP routing.
+- **Authentication**: Built-in authentication mechanisms.
+- **Fragmentation**: Support for breaking large messages into fragments.
+
+### Reactive Streams
+- **Backpressure Support**: Implements the Reactive Streams specification for handling backpressure.
+- **Publisher/Subscriber Pattern**: Uses the publisher/subscriber pattern for stream handling.
+
+## Project Structure
+
+### Main Package (`rsocket/`)
+- **Core Protocol Implementation**: Base classes, frame handling, error codes.
+- **Handlers**: Implementation of different interaction models.
+- **Extensions**: Protocol extensions like routing, authentication.
+- **Transports**: Different transport implementations (TCP, WebSocket, QUIC).
+- **ReactiveX Integration**: Adapters for ReactiveX observables.
+
+### Examples (`examples/`)
+- **Basic Examples**: Simple client-server interactions.
+- **Tutorial**: Step-by-step guide to using the library.
+- **Advanced Use Cases**: Streaming, routing, reconnection, etc.
+- **Bug Reproductions**: Examples demonstrating specific issues.
+
+### Tests (`tests/`)
+- **Unit Tests**: Tests for individual components.
+- **Integration Tests**: Tests for component interactions.
+- **ReactiveX Tests**: Tests for ReactiveX integration.
+
+## Streaming File Example Analysis
+
+The streaming file example demonstrates how to stream a file from server to client using RSocket's request-stream interaction model:
+
+### Server Side
+1. **File Reading**: Uses `aiofiles` to asynchronously read a file in chunks.
+2. **Stream Handler**: Implements a request-stream handler that reads file chunks and sends them to the client.
+3. **Backpressure Handling**: Uses ReactiveX's backpressure mechanisms to control the flow of data.
+4. **Routing**: Uses RSocket's routing capabilities to expose the stream endpoint.
+
+### Client Side
+1. **Stream Request**: Initiates a request-stream interaction with the server.
+2. **Data Processing**: Processes the incoming stream of file chunks.
+3. **ReactiveX Integration**: Uses ReactiveX operators to transform and collect the stream data.
+
+## Key Features and Capabilities
+
+- **Async/Await Support**: Built on Python's asyncio for asynchronous programming.
+- **Backpressure Control**: Implements proper backpressure handling for stream processing.
+- **Extensibility**: Modular design allows for easy extension and customization.
+- **Multiple Transport Support**: Works with various transport protocols.
+- **Reactive Programming**: Integration with ReactiveX for reactive programming patterns.
+- **Routing**: Request routing similar to HTTP frameworks.
+- **Fragmentation**: Support for large messages through fragmentation.
+- **Command Line Interface**: Includes CLI tools for testing and debugging.
+
+## Integration Options
+
+The project supports integration with various Python libraries and frameworks:
+- **ReactiveX**: For reactive programming.
+- **aiohttp/fastapi/quart**: For WebSocket transport.
+- **CloudEvents**: For event-driven architectures.
+- **GraphQL**: For GraphQL API implementation.
+
+## Conclusion
+
+RSocket-py provides a comprehensive implementation of the RSocket protocol in Python, with support for all interaction models, various transports, and extensions. It's designed for building reactive, resilient, and efficient communication between services, particularly in microservice architectures. The project's modular design and extensive examples make it accessible for developers looking to implement RSocket-based communication in their Python applications.

.readthedocs.yaml

@@ -8,10 +8,10 @@ build:
 python:
   install:
     - requirements: docs/requirements.txt
+    - requirements: requirements.txt
     - method: pip
       path: .
-      extra_requirements:
-        - docs
+
 
 sphinx:
   configuration: docs/conf.py

CHANGELOG.rst

@@ -1,9 +1,20 @@
 Changelog
 ---------
 
+v0.4.18
+=======
+- Fixed Stalette/FastAPI implementation and added example using FastAPI server
+
+v0.4.17
+=======
+- python 3.13 support
+- Documentation and example code update
+
 v0.4.16
 =======
-- Channels (django) (https://github.com/django/channels) server support
+- Fix using router request-response with reactivex response
+- Fix examples of consuming the payload of a request-channel
+- Fix the reactivex example of the tutorial application
 
 v0.4.15
 =======

README.md

@@ -17,6 +17,7 @@ You may also install using some **extras**:
 | rx              | ReactiveX ([v3](https://pypi.org/project/Rx/)) integration                                 | [Tutorial](https://rsocket.io/guides/rsocket-py/tutorial/reactivex) |
 | reactivex       | [ReactiveX](https://reactivex.io/) ([v4](https://pypi.org/project/reactivex/)) integration | [Tutorial](https://rsocket.io/guides/rsocket-py/tutorial/reactivex) |
 | aiohttp         | [aiohttp](https://docs.aiohttp.org/en/stable/) Websocket transport (server/client)         | [Tutorial](https://rsocket.io/guides/rsocket-py/tutorial/websocket) |
+| fastapi         | [fastapi](https://github.com/fastapi/fastapi) Websocket transport (server/client)          |                                                                     |
 | channels        | Websocket transport (server only) using channels (django)                                  |                                                                     |
 | quart           | [Quart](https://pgjones.gitlab.io/quart/) Websocket transport (server only)                |                                                                     |
 | quic            | [QUIC](https://github.com/aiortc/aioquic) transport                                        |                                                                     |
@@ -48,6 +49,7 @@ python3 setup.py install
 # Documentation
 
 [Documentation](https://rsocket.io/guides/rsocket-py) is available on the official rsocket.io site.
+[API](https://rsocket.readthedocs.io/en/latest/index.html) documentation is at readthedocs.io.
 
 # Examples
 
@@ -74,6 +76,7 @@ the [Spring RSocket demo](https://github.com/benwilcock/spring-rsocket-demo).
 |                             | ServerWithFragmentation | client_with_routing.py             |                 |
 | server_quart_websocket.py   |                         | client_websocket.py                |                 |
 | server_aiohttp_websocket.py |                         | client_websocket.py                |                 |
+| server_fastapi_websocket.py |                         | client_websocket.py                |                 |
 | server_graphql.py           | ServerWithGraphQL       | client_graphql.py                  |                 |
 
 # Build Status

docs/api.rst

@@ -65,3 +65,4 @@ Transports
 
 .. automodule:: rsocket.transports.transport
     :members:
+

docs/conf.py

@@ -24,7 +24,7 @@
 author = '[email protected]'
 
 # The full version, including alpha/beta/rc tags
-release = '0.4.15'
+release = '0.4.18'
 
 # -- General configuration ---------------------------------------------------
 
@@ -35,7 +35,7 @@
     'sphinx.ext.autodoc',
     'sphinx.ext.autosummary',
     "sphinx.ext.napoleon",
-    "sphinx.ext.viewcode"
+    "sphinx.ext.viewcode",
 ]
 
 # Add any paths that contain templates here, relative to this directory.

docs/extensions.rst

@@ -25,6 +25,18 @@ quart
 .. automodule:: rsocket.transports.quart_websocket
     :members:
 
+websockets
+++++++++++
+
+.. automodule:: rsocket.transports.websockets_transport
+    :members:
+
+asyncwebsockets
++++++++++++++++
+
+.. automodule:: rsocket.transports.asyncwebsockets_transport
+    :members:
+
 quic
 ~~~~
 
@@ -69,3 +81,32 @@ Strategies
 .. automodule:: rsocket.load_balancer.random_client
     :members:
     :inherited-members:
+
+
+ReactiveX
+---------
+
+ReactiveX 4
+~~~~~~~~~~~
+
+.. automodule:: rsocket.reactivex.reactivex_handler
+    :members:
+    :inherited-members:
+
+
+.. automodule:: rsocket.reactivex.reactivex_handler_adapter
+    :members:
+    :inherited-members:
+
+
+ReactiveX 3
+~~~~~~~~~~~
+
+.. automodule:: rsocket.rx_support.rx_handler
+    :members:
+    :inherited-members:
+
+
+.. automodule:: rsocket.rx_support.rx_handler_adapter
+    :members:
+    :inherited-members: