fastapi_websocket_pubsub icon indicating copy to clipboard operation
fastapi_websocket_pubsub copied to clipboard

A fast and durable Pub/Sub channel over Websockets. FastAPI + WebSockets + PubSub == ⚡ 💪 ❤️

Results 14 fastapi_websocket_pubsub issues
Sort by recently updated
recently updated
newest added

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-top-banner](https://github.com/andygongea/OWASP-Benchmark/assets/818805/c518c423-16fe-447e-b67f-ad5a49b5d123) ### 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-top-banner](https://github.com/andygongea/OWASP-Benchmark/assets/818805/c518c423-16fe-447e-b67f-ad5a49b5d123) ### 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...