AsyncAioPikaManager connect

[wangjianweiwei]

python-socketio/socketio/asyncio_aiopika_manager.py

Lines 68 to 76 in 2f0d8bb

	async def _publish(self, data):
	connection = await self._connection()
	channel = await self._channel(connection)
	exchange = await self._exchange(channel)
	await exchange.publish(
	aio_pika.Message(body=pickle.dumps(data),
	delivery_mode=aio_pika.DeliveryMode.PERSISTENT),
	routing_key='*'
	)

A connection is built every time it is publish can this place be improved?

[miguelgrinberg]

Of course. This code was not written by myself, it is from a contributor. If you want to make improvements to it I'll be happy to merge them.

[wangjianweiwei]

Thanks. I'm glad to contribute the code.