@synchronized('_frame_write_lock')
    def write_frame(self, frame):
        """Write frame to connection

        Note that the frame may be destined for any channel. It is permitted to interleave frames
        from different channels.

        :param frame: frame
        :type frame: amqpy.proto.Frame
        """
        try:
            self.write(frame.data)
        except socket.timeout:
            raise
        except (OSError, IOError, socket.error) as exc:
            if _UNAVAIL not in get_errno(exc):
                self.connected = False
            raise
dataset/ETHPy150Open veegee/amqpy/amqpy/transport.py/Transport.write_frame/swapped operands of `not in`