         conn.on_timeout()         self.assert_pending((AF0, 'a'))         self.resolve_connect(AF0, 'a', False)         self.assert_pending((AF0, 'b'))         self.resolve_connect(AF0, 'b', True)         self.assertEqual(future.result(), (AF0, 'b', self.streams['b']))      def test_