fix sans io policy tests

sdk/core/corehttp/corehttp/runtime/pipeline/_base.py

@@ -123,7 +123,9 @@ def __init__(
         self._transport = transport
 
         for policy in policies or []:
-            if isinstance(policy, SansIOHTTPPolicy):
+            if hasattr(policy, "send"):
+                self._impl_policies.append(policy)
+            elif isinstance(policy, SansIOHTTPPolicy):
                 self._impl_policies.append(_SansIOHTTPPolicyRunner(policy))
             elif policy:
                 self._impl_policies.append(policy)

sdk/core/corehttp/corehttp/runtime/pipeline/_base_async.py

@@ -127,7 +127,9 @@ def __init__(
         self._transport = transport
 
         for policy in policies or []:
-            if isinstance(policy, SansIOHTTPPolicy):
+            if hasattr(policy, "send"):
+                self._impl_policies.append(policy)
+            elif isinstance(policy, SansIOHTTPPolicy):
                 self._impl_policies.append(_SansIOAsyncHTTPPolicyRunner(policy))
             elif policy:
                 self._impl_policies.append(policy)

sdk/core/corehttp/tests/async_tests/test_pipeline_async.py

@@ -28,6 +28,13 @@
 
 @pytest.mark.asyncio
 async def test_sans_io_exception():
+
+    class SansIOHTTPPolicyImpl(SansIOHTTPPolicy):
+        def on_request(self, request):
+            pass
+        def on_response(self, request, response):
+            pass
+
     class BrokenSender(AsyncHttpTransport):
         async def send(self, request, **config):
             raise ValueError("Broken")
@@ -42,7 +49,7 @@ async def __aexit__(self, exc_type, exc_value, traceback):
             """Raise any exception triggered within the runtime context."""
             return self.close()
 
-    pipeline = AsyncPipeline(BrokenSender(), [SansIOHTTPPolicy()])
+    pipeline = AsyncPipeline(BrokenSender(), [SansIOHTTPPolicyImpl()])
 
     req = HttpRequest("GET", "/")
     with pytest.raises(ValueError):

sdk/core/corehttp/tests/test_pipeline.py

@@ -31,6 +31,13 @@
 
 
 def test_sans_io_exception():
+
+    class SansIOHTTPPolicyImpl(SansIOHTTPPolicy):
+        def on_request(self, request):
+            pass
+        def on_response(self, request, response):
+            pass
+
     class BrokenSender(HttpTransport):
         def send(self, request, **config):
             raise ValueError("Broken")
@@ -45,7 +52,7 @@ def __exit__(self, exc_type, exc_value, traceback):
             """Raise any exception triggered within the runtime context."""
             return self.close()
 
-    pipeline = Pipeline(BrokenSender(), [SansIOHTTPPolicy()])
+    pipeline = Pipeline(BrokenSender(), [SansIOHTTPPolicyImpl()])
 
     req = HttpRequest("GET", "/")
     with pytest.raises(ValueError):