Instead of .take() for read and write stream, maybe just consume the connection and return it after success and disallow clone() for the connection
Instead of .take() for read and write stream, maybe just consume the connection and return it after success and disallow clone() for the connection