         self.connect_futures.pop((AF0, 'c'))         self.assertTrue(self.streams.pop('c').closed)         self.assert_pending()         self.assertEqual(len(conn.streams), 0)         self.assert_connector_streams_closed(conn)         self.assertEqual(future.result(), (AF0, 'a', self.streams['a']))      def test_