fastapi_websocket_pubsub
fastapi_websocket_pubsub copied to clipboard
A fast and durable Pub/Sub channel over Websockets. FastAPI + WebSockets + PubSub == ⚡ 💪 ❤️
This PR was automatically created by Snyk using the credentials of a real user.Snyk has created this PR to fix one or more vulnerable packages in the `pip` dependencies of...
Hello people! First and foremost, I really appreciate your project! I am also using it heavily in a library I am making - [eventhive](https://github.com/operatorequals/eventhive). So, I am trying to use...
This PR was automatically created by Snyk using the credentials of a real user.Snyk has created this PR to fix one or more vulnerable packages in the `pip` dependencies of...
Moving the broadcaster channel `disconnect` call to `__aexit__` would not necessarily behave the same as calling `disconnect` upon exiting the reader task.
This PR was automatically created by Snyk using the credentials of a real user. ### Snyk has created this PR to fix 1 vulnerabilities in the pip dependencies of this...
This PR was automatically created by Snyk using the credentials of a real user. ### Snyk has created this PR to fix 1 vulnerabilities in the pip dependencies of this...
`connect` method is important to be able to retry connections (Specifically from opal server) without using the cumbersome `__aenter__`
```python3 from fastapi_websocket_pubsub import PubSubEndpoint from pydantic import BaseModel from datetime import datetime class ActivityLog(BaseModel): channel: str action: str user_id: str created: datetime endpoint = PubSubEndpoint( broadcaster="redis://user:password@host:port" ) @shared_router.websocket("/pubsub") async...