Implemented async Couchbase communication via Observable in CouchbaseWrapper.deleteDocument(). Fixed wrong handling of queueSize incrementation for mark document as read and delete document.