def test_disconnect_sync_rpc_event(self):
    disconnect_sync_rpc_event_mock = mock.patch('magma.magmad.events.disconnected_sync_rpc_stream')
    with disconnect_sync_rpc_event_mock as disconnect_sync_rpc_streams:
        self._sync_rpc_client._cleanup_and_reconnect()
        disconnect_sync_rpc_streams.assert_called_once_with()
def test_disconnect_sync_rpc_event(self):
    disconnect_sync_rpc_event_mock = mock.patch('magma.magmad.events.disconnected_sync_rpc_stream')
    with disconnect_sync_rpc_event_mock as disconnect_sync_rpc_streams:
        self._sync_rpc_client._cleanup_and_reconnect()
        disconnect_sync_rpc_streams.assert_called_once_with()