When queue errors, continue processing

Author: beaucollins

src/simperium/channel.js

@@ -25,7 +25,7 @@ internal.changeObject = function( id, change ) {
 	var applyChange = internal.performChange.bind( this, change );
 
 	this.networkQueue.queueFor( id ).add( function( done ) {
-		return applyChange().then( done );
+		return applyChange().then( done, done );
 	} );
 };
 

test/simperium/channel_test.js

@@ -163,6 +163,13 @@ describe( 'Channel', function() {
 			bucket.update( 'mock-id', data );
 		} );
 
+		it( 'should ignore duplicate change error if nothing to acknowledge', ( done ) => {
+			let id = 'mock-id', ccid = 'mock-ccid'
+			// queue should emit a finish event when the change is processed
+			channel.networkQueue.queueFor( id ).on( 'finish', () => done() )
+			channel.handleMessage( 'c:' + JSON.stringify( [ { ccids: [ ccid ], error: 409, id }] ) )
+		} )
+
 		it( 'should resend sent but unacknowledged changes on reconnect', () => new Promise( resolve => {
 			channel.localQueue.sent['fake-ccid'] = { fake: 'change', ccid: 'fake-ccid' }