code: def test_connect_pipe_cancel(self):
      exc = OSError()
      exc.winerror = _overlapped.ERROR_PIPE_BUSY
      with mock.patch.object(
          _overlapped, "ConnectPipe", side_effect=exc
      ) as connect:
          coro = self.loop._proactor.connect_pipe("pipe_address")
          task = self.loop.create_task(coro)
  
          # check that it's possible to cancel connect_pipe()
          task.cancel()
          with self.assertRaises(asyncio.CancelledError):
              self.loop.run_until_complete(task)
  
imports: import os
  import signal
  import socket
  import sys
  import time
  import threading
  import unittest
  from unittest import mock
  import _overlapped
  import _winapi
  import asyncio
  from asyncio import windows_events
  from test.test_asyncio import utils
label_desc: Use image node_id 5 for calling the ProactorTests obj's underlying member method code with example usage: obj.test_connect_pipe_cancel() without return types