Catch writer.wait_closed() exception to avoid command hanging. #33

[Ivashkaization]

Fixes #33

As asyncio docs says about StreamWriter.write method:

The method attempts to write the data to the underlying socket immediately. If that fails, the data is queued in an internal write buffer until it can be sent.

Also, wait_closed is writing data left in buffer before exiting

However, in library code any exception in wait_closed is ignored:

ansq/ansq/tcp/connection.py

Lines 122 to 128 in cb4c722

	assert self._writer is not None
	try:
	self._writer.close()
	if sys.version_info >= (3, 7):
	await self._writer.wait_closed()
	finally:
	pass

And code intended to unhang command located below is never reached

ansq/ansq/tcp/connection.py

Lines 130 to 133 in cb4c722

	for future, callback in self._cmd_waiters:
	if not future.cancelled():
	future.set_exception(ConnectionClosedError("Connection is closed"))
	callback is not None and callback(None)

[atugushev]

Nice catch 👍🏻 Thanks!

[atugushev]

@GinTR1k it seems python-test workflow is disabled due to lack of activity. Could you please enable it?

[GinTR1k]

Hi!

I am no longer the maintainer, sorry. I think @shalakhin would help with that.

[shalakhin]

Hi guys. Accept this PR. Thank you for PR to the project!

[lig]

@shalakhin could we have a release with this fix?

[shalakhin]

@shalakhin could we have a release with this fix?

Hey! Yes, this week we will release a new version with accepted and merged PRs! Also thanks everyone for contributions!