Rob Blackbourn

How do I cancel a streaming response on shutdown?

3

The code below simulates a server sent event with uvicorn 0.9. When run, if the HTTP request is *not* initiated the lifespan startup and shutdown events get called correctly on...

connection pool with cluster

1

I'm connecting to an HA RabbitMQ cluster. My understanding is that a RabbitMQ cluster has a single master node with the remaining as slaves. Communication to a slave gets forwarded...

Cluster connections (feature request)

1

I recently had to deal with cluster failures in my production environment. I created a test environment using [blockade](https://github.com/worstcase/blockade) following this [blog](https://jack-vanlightly.com/blog/2018/9/10/how-to-lose-messages-on-a-rabbitmq-cluster), and found that aiorabbit is aware when it's...

Publishing from a consumer

2

Hi, When I publish from a consume loop I get the error below. Would you expect this to work, or should I be using a separate connection for consuming and...

Connection.insertArrowTable fails for esbuild typescript

6

### What happens? The method `Connection.insertArrowTable` silently fails in a typescript program. ### To Reproduce ## bare-node works Change the query in `examples/bare-node/index.cjs` from: ```js const conn = await db.connect();...