async def METHOD_NAME(self, data: bytes):
    with self._conflict_detector:
        if self._handle_holder.closed:
            raise _core.ClosedResourceError("this pipe is already closed")
        if not data:
            await _core.checkpoint()
            return
        try:
            written = await _core.write_overlapped(self._handle_holder.handle, data)
        except BrokenPipeError as ex:
            raise _core.BrokenResourceError from ex
        # By my reading of MSDN, this assert is guaranteed to pass so long
        # as the pipe isn't in nonblocking mode, but... let's just
        # double-check.
        assert written == len(data)