diff --git a/akonadi/resourcebase.cpp b/akonadi/resourcebase.cpp
index 82ddffb29..0b262500e 100644
--- a/akonadi/resourcebase.cpp
+++ b/akonadi/resourcebase.cpp
@@ -1,555 +1,565 @@
 /*
     Copyright (c) 2006 Till Adam <adam@kde.org>
     Copyright (c) 2007 Volker Krause <vkrause@kde.org>
 
     This library is free software; you can redistribute it and/or modify it
     under the terms of the GNU Library General Public License as published by
     the Free Software Foundation; either version 2 of the License, or (at your
     option) any later version.
 
     This library is distributed in the hope that it will be useful, but WITHOUT
     ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
     FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Library General Public
     License for more details.
 
     You should have received a copy of the GNU Library General Public License
     along with this library; see the file COPYING.LIB.  If not, write to the
     Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
     02110-1301, USA.
 */
 
 #include "resourcebase.h"
 #include "agentbase_p.h"
 
 #include "resourceadaptor.h"
 #include "collectiondeletejob.h"
 #include "collectionsync.h"
 #include "itemsync.h"
 #include "resourcescheduler.h"
 #include "tracerinterface.h"
 #include "xdgbasedirs_p.h"
 
 #include "changerecorder.h"
 #include "collectionfetchjob.h"
 #include "collectionmodifyjob.h"
 #include "itemfetchjob.h"
 #include "itemfetchscope.h"
 #include "itemmodifyjob.h"
 #include "itemmodifyjob_p.h"
 #include "session.h"
 
 #include <kaboutdata.h>
 #include <kcmdlineargs.h>
 #include <kdebug.h>
 #include <klocale.h>
 
 #include <QtCore/QDebug>
 #include <QtCore/QDir>
 #include <QtCore/QHash>
 #include <QtCore/QSettings>
 #include <QtCore/QTimer>
 #include <QtGui/QApplication>
 #include <QtDBus/QtDBus>
 
 using namespace Akonadi;
 
 class Akonadi::ResourceBasePrivate : public AgentBasePrivate
 {
   public:
     ResourceBasePrivate( ResourceBase *parent )
       : AgentBasePrivate( parent ),
         scheduler( 0 ),
         mItemSyncer( 0 )
     {
       mStatusMessage = defaultReadyMessage();
     }
 
     Q_DECLARE_PUBLIC( ResourceBase )
 
     void delayedInit()
     {
       if ( !QDBusConnection::sessionBus().registerService( QLatin1String( "org.freedesktop.Akonadi.Resource." ) + mId ) )
         kFatal() << "Unable to register service at D-Bus: " << QDBusConnection::sessionBus().lastError().message();
       AgentBasePrivate::delayedInit();
     }
 
     virtual void changeProcessed()
     {
       mMonitor->changeProcessed();
       if ( !mMonitor->isEmpty() )
         scheduler->scheduleChangeReplay();
       scheduler->taskDone();
     }
 
     void slotDeliveryDone( KJob* job );
     void slotCollectionSyncDone( KJob *job );
     void slotLocalListDone( KJob *job );
     void slotSynchronizeCollection( const Collection &col );
     void slotCollectionListDone( KJob *job );
 
     void slotItemSyncDone( KJob *job );
 
     void slotPercent( KJob* job, unsigned long percent );
     void slotDeleteResourceCollection();
     void slotDeleteResourceCollectionDone( KJob *job );
     void slotCollectionDeletionDone( KJob *job );
 
     QString mName;
 
     // synchronize states
     Collection currentCollection;
 
     ResourceScheduler *scheduler;
     ItemSync *mItemSyncer;
 };
 
 ResourceBase::ResourceBase( const QString & id )
   : AgentBase( new ResourceBasePrivate( this ), id )
 {
   Q_D( ResourceBase );
 
   new ResourceAdaptor( this );
 
   const QString name = d->mSettings->value( QLatin1String( "Resource/Name" ) ).toString();
   if ( !name.isEmpty() )
     d->mName = name;
 
   d->scheduler = new ResourceScheduler( this );
 
   d->mMonitor->setChangeRecordingEnabled( true );
   connect( d->mMonitor, SIGNAL(changesAdded()),
            d->scheduler, SLOT(scheduleChangeReplay()) );
 
   d->mMonitor->setResourceMonitored( d->mId.toLatin1() );
 
   connect( d->scheduler, SIGNAL(executeFullSync()),
            SLOT(retrieveCollections()) );
   connect( d->scheduler, SIGNAL(executeCollectionTreeSync()),
            SLOT(retrieveCollections()) );
   connect( d->scheduler, SIGNAL(executeCollectionSync(Akonadi::Collection)),
            SLOT(slotSynchronizeCollection(Akonadi::Collection)) );
   connect( d->scheduler, SIGNAL(executeItemFetch(Akonadi::Item,QSet<QByteArray>)),
            SLOT(retrieveItem(Akonadi::Item,QSet<QByteArray>)) );
   connect( d->scheduler, SIGNAL(executeResourceCollectionDeletion()),
            SLOT(slotDeleteResourceCollection()) );
   connect( d->scheduler, SIGNAL( status( int, QString ) ),
            SIGNAL( status( int, QString ) ) );
   connect( d->scheduler, SIGNAL(executeChangeReplay()),
            d->mMonitor, SLOT(replayNext()) );
   connect( d->scheduler, SIGNAL(fullSyncComplete()), SIGNAL(synchronized()) );
   connect( this, SIGNAL(synchronized()), d->scheduler, SLOT(taskDone()) );
 
   d->scheduler->setOnline( d->mOnline );
   if ( !d->mMonitor->isEmpty() )
     d->scheduler->scheduleChangeReplay();
 }
 
 ResourceBase::~ResourceBase()
 {
 }
 
 void ResourceBase::synchronize()
 {
   d_func()->scheduler->scheduleFullSync();
 }
 
 void ResourceBase::setName( const QString &name )
 {
   Q_D( ResourceBase );
   if ( name == d->mName )
     return;
 
   // TODO: rename collection
   d->mName = name;
 
   if ( d->mName.isEmpty() || d->mName == d->mId )
     d->mSettings->remove( QLatin1String( "Resource/Name" ) );
   else
     d->mSettings->setValue( QLatin1String( "Resource/Name" ), d->mName );
 
   d->mSettings->sync();
 
   emit nameChanged( d->mName );
 }
 
 QString ResourceBase::name() const
 {
   Q_D( const ResourceBase );
   if ( d->mName.isEmpty() )
     return d->mId;
   else
     return d->mName;
 }
 
 static char* sAppName = 0;
 
 QString ResourceBase::parseArguments( int argc, char **argv )
 {
   QString identifier;
   if ( argc < 3 ) {
     kDebug( 5250 ) << "Not enough arguments passed...";
     exit( 1 );
   }
 
   for ( int i = 1; i < argc - 1; ++i ) {
     if ( QLatin1String( argv[ i ] ) == QLatin1String( "--identifier" ) )
       identifier = QLatin1String( argv[ i + 1 ] );
   }
 
   if ( identifier.isEmpty() ) {
     kDebug( 5250 ) << "Identifier argument missing";
     exit( 1 );
   }
 
   sAppName = qstrdup( identifier.toLatin1().constData() );
   KCmdLineArgs::init( argc, argv, sAppName, 0,
                       ki18nc("@title, application name", "Akonadi Resource"), "0.1",
                       ki18nc("@title, application description", "Akonadi Resource") );
 
   KCmdLineOptions options;
   options.add("identifier <argument>",
               ki18nc("@label, commandline option", "Resource identifier"));
   KCmdLineArgs::addCmdLineOptions( options );
 
   return identifier;
 }
 
 int ResourceBase::init( ResourceBase *r )
 {
   QApplication::setQuitOnLastWindowClosed( false );
   int rv = kapp->exec();
   delete r;
   delete[] sAppName;
   return rv;
 }
 
 void ResourceBase::itemRetrieved( const Item &item )
 {
   Q_D( ResourceBase );
   Q_ASSERT( d->scheduler->currentTask().type == ResourceScheduler::FetchItem );
   if ( !item.isValid() ) {
     QDBusMessage reply( d->scheduler->currentTask().dbusMsg );
     reply << false;
     QDBusConnection::sessionBus().send( reply );
     d->scheduler->taskDone();
     return;
   }
 
   Item i( item );
   QSet<QByteArray> requestedParts = d->scheduler->currentTask().itemParts;
   foreach ( const QByteArray &part, requestedParts ) {
     if ( !item.loadedPayloadParts().contains( part ) ) {
       kWarning( 5250 ) << "Item does not provide part" << part;
     }
   }
 
   ItemModifyJob *job = new ItemModifyJob( i );
   // FIXME: remove once the item with which we call retrieveItem() has a revision number
   job->disableRevisionCheck();
   connect( job, SIGNAL(result(KJob*)), SLOT(slotDeliveryDone(KJob*)) );
 }
 
 void ResourceBasePrivate::slotDeliveryDone(KJob * job)
 {
   Q_Q( ResourceBase );
   Q_ASSERT( scheduler->currentTask().type == ResourceScheduler::FetchItem );
   QDBusMessage reply( scheduler->currentTask().dbusMsg );
   if ( job->error() ) {
     emit q->error( QLatin1String( "Error while creating item: " ) + job->errorString() );
     reply << false;
   } else {
     reply << true;
   }
   QDBusConnection::sessionBus().send( reply );
   scheduler->taskDone();
 }
 
 void ResourceBasePrivate::slotDeleteResourceCollection()
 {
   Q_Q( ResourceBase );
 
   CollectionFetchJob *job = new CollectionFetchJob( Collection::root(), CollectionFetchJob::FirstLevel );
   job->setResource( q->identifier() );
   connect( job, SIGNAL(result(KJob*)), q, SLOT(slotDeleteResourceCollectionDone(KJob*)) );
 }
 
 void ResourceBasePrivate::slotDeleteResourceCollectionDone( KJob *job )
 {
   Q_Q( ResourceBase );
   if ( job->error() ) {
     emit q->error( job->errorString() );
     scheduler->taskDone();
   } else {
     const CollectionFetchJob *fetchJob = static_cast<const CollectionFetchJob*>( job );
 
     if ( !fetchJob->collections().isEmpty() ) {
       CollectionDeleteJob *job = new CollectionDeleteJob( fetchJob->collections().first() );
       connect( job, SIGNAL( result( KJob* ) ), q, SLOT( slotCollectionDeletionDone( KJob* ) ) );
     } else {
       // there is no resource collection, so just ignore the request
       scheduler->taskDone();
     }
   }
 }
 
 void ResourceBasePrivate::slotCollectionDeletionDone( KJob *job )
 {
   Q_Q( ResourceBase );
   if ( job->error() ) {
     emit q->error( job->errorString() );
   }
 
   scheduler->taskDone();
 }
 
 void ResourceBase::changeCommitted(const Item& item)
 {
   Q_D( ResourceBase );
   ItemModifyJob *job = new ItemModifyJob( item );
   job->d_func()->setClean();
   job->disableRevisionCheck(); // TODO: remove, but where/how do we handle the error?
   job->ignorePayload(); // we only want to reset the dirty flag and update the remote id
   d->changeProcessed();
 }
 
 void ResourceBase::changeCommitted( const Collection &collection )
 {
   Q_D( ResourceBase );
   CollectionModifyJob *job = new CollectionModifyJob( collection );
   Q_UNUSED( job );
   //TODO: error checking
   d->changeProcessed();
 }
 
 bool ResourceBase::requestItemDelivery( qint64 uid, const QString & remoteId,
                                         const QString &mimeType, const QStringList &_parts )
 {
   Q_D( ResourceBase );
   if ( !isOnline() ) {
     emit error( i18nc( "@info", "Cannot fetch item in offline mode." ) );
     return false;
   }
 
   setDelayedReply( true );
   // FIXME: we need at least the revision number too
   Item item( uid );
   item.setMimeType( mimeType );
   item.setRemoteId( remoteId );
 
   QSet<QByteArray> parts;
   Q_FOREACH( const QString &str, _parts )
     parts.insert( str.toLatin1() );
 
   d->scheduler->scheduleItemFetch( item, parts, message().createReply() );
 
   return true;
 }
 
 void ResourceBase::collectionsRetrieved(const Collection::List & collections)
 {
   Q_D( ResourceBase );
   CollectionSync *syncer = new CollectionSync( d->mId );
   syncer->setRemoteCollections( collections );
   connect( syncer, SIGNAL(result(KJob*)), SLOT(slotCollectionSyncDone(KJob*)) );
 }
 
 void ResourceBase::collectionsRetrievedIncremental(const Collection::List & changedCollections, const Collection::List & removedCollections)
 {
   Q_D( ResourceBase );
   CollectionSync *syncer = new CollectionSync( d->mId );
   syncer->setRemoteCollections( changedCollections, removedCollections );
   connect( syncer, SIGNAL(result(KJob*)), SLOT(slotCollectionSyncDone(KJob*)) );
 }
 
 void ResourceBasePrivate::slotCollectionSyncDone(KJob * job)
 {
   Q_Q( ResourceBase );
   if ( job->error() ) {
     emit q->error( job->errorString() );
   } else {
     if ( scheduler->currentTask().type == ResourceScheduler::SyncAll ) {
       CollectionFetchJob *list = new CollectionFetchJob( Collection::root(), CollectionFetchJob::Recursive );
       list->setResource( mId );
       q->connect( list, SIGNAL(result(KJob*)), q, SLOT(slotLocalListDone(KJob*)) );
       return;
     }
   }
   scheduler->taskDone();
 }
 
 void ResourceBasePrivate::slotLocalListDone(KJob * job)
 {
   Q_Q( ResourceBase );
   if ( job->error() ) {
     emit q->error( job->errorString() );
   } else {
     Collection::List cols = static_cast<CollectionFetchJob*>( job )->collections();
     foreach ( const Collection &col, cols ) {
       scheduler->scheduleSync( col );
     }
     scheduler->scheduleFullSyncCompletion();
   }
   scheduler->taskDone();
 }
 
 void ResourceBasePrivate::slotSynchronizeCollection( const Collection &col )
 {
   Q_Q( ResourceBase );
   currentCollection = col;
   // check if this collection actually can contain anything
   QStringList contentTypes = currentCollection.contentMimeTypes();
   contentTypes.removeAll( Collection::mimeType() );
   if ( !contentTypes.isEmpty() ) {
     emit q->status( AgentBase::Running, i18nc( "@info:status", "Syncing collection '%1'", currentCollection.name() ) );
     q->retrieveItems( currentCollection );
     return;
   }
   scheduler->taskDone();
 }
 
 void ResourceBase::itemsRetrievalDone()
 {
   Q_D( ResourceBase );
   // streaming enabled, so finalize the sync
   if ( d->mItemSyncer ) {
     d->mItemSyncer->deliveryDone();
   }
   // user did the sync himself, we are done now
   else {
     d->scheduler->taskDone();
   }
 }
 
 void ResourceBase::clearCache()
 {
   Q_D( ResourceBase );
   d->scheduler->scheduleResourceCollectionDeletion();
 }
 
 Collection ResourceBase::currentCollection() const
 {
   Q_D( const ResourceBase );
   Q_ASSERT_X( d->scheduler->currentTask().type == ResourceScheduler::SyncCollection ,
               "ResourceBase::currentCollection()",
               "Trying to access current collection although no item retrieval is in progress" );
   return d->currentCollection;
 }
 
 Item ResourceBase::currentItem() const
 {
   Q_D( const ResourceBase );
   Q_ASSERT_X( d->scheduler->currentTask().type == ResourceScheduler::FetchItem ,
               "ResourceBase::currentItem()",
               "Trying to access current item although no item retrieval is in progress" );
   return d->scheduler->currentTask().item;
 }
 
 void ResourceBase::synchronizeCollectionTree()
 {
   d_func()->scheduler->scheduleCollectionTreeSync();
 }
 
 void ResourceBase::cancelTask()
 {
-  d_func()->changeProcessed();
+  Q_D( ResourceBase );
+  switch ( d->scheduler->currentTask().type ) {
+    case ResourceScheduler::FetchItem:
+      itemRetrieved( Item() ); // sends the error reply and
+      break;
+    case ResourceScheduler::ChangeReplay:
+      d->changeProcessed();
+      break;
+    default:
+      d->scheduler->taskDone();
+  }
 }
 
 void ResourceBase::cancelTask( const QString &msg )
 {
   cancelTask();
 
   emit error( msg );
 }
 
 void ResourceBase::doSetOnline( bool state )
 {
   d_func()->scheduler->setOnline( state );
 }
 
 void ResourceBase::synchronizeCollection(qint64 collectionId )
 {
   CollectionFetchJob* job = new CollectionFetchJob( Collection(collectionId), CollectionFetchJob::Base );
   job->setResource( identifier() );
   connect( job, SIGNAL(result(KJob*)), SLOT(slotCollectionListDone(KJob*)) );
 }
 
 void ResourceBasePrivate::slotCollectionListDone( KJob *job )
 {
   if ( !job->error() ) {
     Collection::List list = static_cast<CollectionFetchJob*>( job )->collections();
     if ( !list.isEmpty() ) {
       Collection col = list.first();
       scheduler->scheduleSync( col );
     }
   }
   // TODO: error handling
 }
 
 void ResourceBase::setTotalItems( int amount )
 {
   kDebug() << amount;
   Q_D( ResourceBase );
   setItemStreamingEnabled( true );
   d->mItemSyncer->setTotalItems( amount );
 }
 
 void ResourceBase::setItemStreamingEnabled( bool enable )
 {
   Q_D( ResourceBase );
   Q_ASSERT_X( d->scheduler->currentTask().type == ResourceScheduler::SyncCollection,
               "ResourceBase::setItemStreamingEnabled()",
               "Calling setItemStreamingEnabled() although no item retrieval is in progress" );
   if ( !d->mItemSyncer ) {
     d->mItemSyncer = new ItemSync( currentCollection() );
     connect( d->mItemSyncer, SIGNAL(percent(KJob*,unsigned long)), SLOT(slotPercent(KJob*,unsigned long)) );
     connect( d->mItemSyncer, SIGNAL(result(KJob*)), SLOT(slotItemSyncDone(KJob*)) );
   }
   d->mItemSyncer->setStreamingEnabled( enable );
 }
 
 void ResourceBase::itemsRetrieved( const Item::List &items )
 {
   Q_D( ResourceBase );
   Q_ASSERT_X( d->scheduler->currentTask().type == ResourceScheduler::SyncCollection,
               "ResourceBase::itemsRetrieved()",
               "Calling itemsRetrieved() although no item retrieval is in progress" );
   if ( !d->mItemSyncer ) {
     d->mItemSyncer = new ItemSync( currentCollection() );
     connect( d->mItemSyncer, SIGNAL(percent(KJob*,unsigned long)), SLOT(slotPercent(KJob*,unsigned long)) );
     connect( d->mItemSyncer, SIGNAL(result(KJob*)), SLOT(slotItemSyncDone(KJob*)) );
   }
   d->mItemSyncer->setFullSyncItems( items );
 }
 
 void ResourceBase::itemsRetrievedIncremental(const Item::List &changedItems, const Item::List &removedItems)
 {
   Q_D( ResourceBase );
   Q_ASSERT_X( d->scheduler->currentTask().type == ResourceScheduler::SyncCollection,
               "ResourceBase::itemsRetrievedIncremental()",
               "Calling itemsRetrievedIncremental() although no item retrieval is in progress" );
   if ( !d->mItemSyncer ) {
     d->mItemSyncer = new ItemSync( currentCollection() );
     connect( d->mItemSyncer, SIGNAL(percent(KJob*,unsigned long)), SLOT(slotPercent(KJob*,unsigned long)) );
     connect( d->mItemSyncer, SIGNAL(result(KJob*)), SLOT(slotItemSyncDone(KJob*)) );
   }
   d->mItemSyncer->setIncrementalSyncItems( changedItems, removedItems );
 }
 
 void ResourceBasePrivate::slotItemSyncDone( KJob *job )
 {
   mItemSyncer = 0;
   Q_Q( ResourceBase );
   if ( job->error() ) {
     emit q->error( job->errorString() );
   }
   scheduler->taskDone();
 }
 
 void ResourceBasePrivate::slotPercent( KJob *job, unsigned long percent )
 {
   Q_Q( ResourceBase );
   Q_UNUSED( job );
   emit q->percent( percent );
 }
 
 #include "resourcebase.moc"
diff --git a/akonadi/tests/itemsynctest.cpp b/akonadi/tests/itemsynctest.cpp
index 10bf61c21..8ae700a8e 100644
--- a/akonadi/tests/itemsynctest.cpp
+++ b/akonadi/tests/itemsynctest.cpp
@@ -1,173 +1,174 @@
 /*
     Copyright (c) 2008 Volker Krause <vkrause@kde.org>
 
     This library is free software; you can redistribute it and/or modify it
     under the terms of the GNU Library General Public License as published by
     the Free Software Foundation; either version 2 of the License, or (at your
     option) any later version.
 
     This library is distributed in the hope that it will be useful, but WITHOUT
     ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
     FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Library General Public
     License for more details.
 
     You should have received a copy of the GNU Library General Public License
     along with this library; see the file COPYING.LIB.  If not, write to the
     Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
     02110-1301, USA.
 */
 
 #include "test_utils.h"
 
 #include <akonadi/agentmanager.h>
 #include <akonadi/agentinstance.h>
 #include <akonadi/control.h>
 #include <akonadi/collection.h>
 #include <akonadi/item.h>
 #include <akonadi/itemfetchjob.h>
 #include <akonadi/itemfetchscope.h>
 #include <akonadi/itemsync.h>
 
 #include <QtCore/QObject>
 #include <QSignalSpy>
 
 #include <qtest_akonadi.h>
 
 using namespace Akonadi;
 
 Q_DECLARE_METATYPE( KJob* )
 
 class ItemsyncTest : public QObject
 {
   Q_OBJECT
   private:
     Item::List fetchItems( const Collection &col )
     {
       ItemFetchJob *fetch = new ItemFetchJob( col, this );
       fetch->fetchScope().fetchFullPayload();
       fetch->fetchScope().fetchAllAttributes();
+      fetch->fetchScope().setCacheOnly( true ); // resources are switched off anyway
       Q_ASSERT( fetch->exec() );
       Q_ASSERT( !fetch->items().isEmpty() );
       return fetch->items();
     }
 
   private slots:
     void initTestCase()
     {
       Control::start();
       qRegisterMetaType<KJob*>();
 
       // switch all resources offline to reduce interference from them
       foreach ( Akonadi::AgentInstance agent, Akonadi::AgentManager::self()->instances() )
         agent.setIsOnline( false );
     }
 
     void testFullSync()
     {
       const Collection col = Collection( collectionIdFromPath( "res1/foo" ) );
       QVERIFY( col.isValid() );
       Item::List origItems = fetchItems( col );
 
       ItemSync* syncer = new ItemSync( col );
       syncer->setFullSyncItems( origItems );
       QVERIFY( syncer->exec() );
 
       Item::List resultItems = fetchItems( col );
       QCOMPARE( resultItems.count(), origItems.count() );
     }
 
     void testFullStreamingSync()
     {
       const Collection col = Collection( collectionIdFromPath( "res1/foo" ) );
       QVERIFY( col.isValid() );
       Item::List origItems = fetchItems( col );
 
       ItemSync* syncer = new ItemSync( col );
       QSignalSpy spy( syncer, SIGNAL(result(KJob*)) );
       QVERIFY( spy.isValid() );
       syncer->setTotalItems( origItems.count() );
       QTest::qWait( 10 );
       QCOMPARE( spy.count(), 0 );
 
       for ( int i = 0; i < origItems.count(); ++i ) {
         Item::List l;
         l << origItems[i];
         syncer->setFullSyncItems( l );
         if ( i < origItems.count() - 1 )
           QTest::qWait( 10 ); // enter the event loop so itemsync actually can do something
         QCOMPARE( spy.count(), 0 );
       }
       QTest::qWait( 1000 ); // let it finish its job
       QCOMPARE( spy.count(), 1 );
       KJob *job = spy.at( 0 ).at( 0 ).value<KJob*>();
       QVERIFY( job );
       QCOMPARE( job->error(), 0 );
 
       Item::List resultItems = fetchItems( col );
       QCOMPARE( resultItems.count(), origItems.count() );
     }
 
     void testIncrementalSync()
     {
       const Collection col = Collection( collectionIdFromPath( "res1/foo" ) );
       QVERIFY( col.isValid() );
       Item::List origItems = fetchItems( col );
 
       ItemSync* syncer = new ItemSync( col );
       syncer->setIncrementalSyncItems( origItems, Item::List() );
       QVERIFY( syncer->exec() );
 
       Item::List resultItems = fetchItems( col );
       QCOMPARE( resultItems.count(), origItems.count() );
     }
 
     void testIncrementalStreamingSync()
     {
       const Collection col = Collection( collectionIdFromPath( "res1/foo" ) );
       QVERIFY( col.isValid() );
       Item::List origItems = fetchItems( col );
 
       ItemSync* syncer = new ItemSync( col );
       QSignalSpy spy( syncer, SIGNAL(result(KJob*)) );
       QVERIFY( spy.isValid() );
       syncer->setStreamingEnabled( true );
       QTest::qWait( 10 );
       QCOMPARE( spy.count(), 0 );
 
       for ( int i = 0; i < origItems.count(); ++i ) {
         Item::List l;
         l << origItems[i];
         syncer->setIncrementalSyncItems( l, Item::List() );
         if ( i < origItems.count() - 1 )
           QTest::qWait( 10 ); // enter the event loop so itemsync actually can do something
         QCOMPARE( spy.count(), 0 );
       }
       syncer->deliveryDone();
       QTest::qWait( 1000 ); // let it finish its job
       QCOMPARE( spy.count(), 1 );
       KJob *job = spy.at( 0 ).at( 0 ).value<KJob*>();
       QVERIFY( job );
       QCOMPARE( job->error(), 0 );
 
       Item::List resultItems = fetchItems( col );
       QCOMPARE( resultItems.count(), origItems.count() );
     }
 
     void testEmptyIncrementalSync()
     {
       const Collection col = Collection( collectionIdFromPath( "res1/foo" ) );
       QVERIFY( col.isValid() );
       Item::List origItems = fetchItems( col );
 
       ItemSync* syncer = new ItemSync( col );
       syncer->setIncrementalSyncItems( Item::List(), Item::List() );
       QVERIFY( syncer->exec() );
 
       Item::List resultItems = fetchItems( col );
       QCOMPARE( resultItems.count(), origItems.count() );
     }
 };
 
 QTEST_AKONADIMAIN( ItemsyncTest, NoGUI )
 
 #include "itemsynctest.moc"