Fix BulkAll cancelling integration tests

Decreased time to wait for bulks from 3 seconds (which might be too
lenient) to 1 second.

Author: gmarz

src/Tests/Document/Multiple/BulkAll/BulkAllApiTests.cs

@@ -34,7 +34,7 @@ public BulkAllApiTests(IntrusiveOperationCluster cluster, EndpointUsage usage)
 			this._client = cluster.Client;
 		}
 
-		[I]
+		[I]
 		public void ReturnsExpectedResponse()
 		{
 			var index = CreateIndexName();
@@ -44,24 +44,24 @@ public void ReturnsExpectedResponse()
 			var pages = 100;
 			var seenPages = 0;
 			var numberOfDocuments = size * pages;
-			var documents = this.CreateLazyStreamOfDocuments(numberOfDocuments);
-
-			//first we setup our cold observable
+			var documents = this.CreateLazyStreamOfDocuments(numberOfDocuments);
+
+			//first we setup our cold observable
 			var observableBulk = this._client.BulkAll(documents, f => f
 				.MaxDegreeOfParallelism(8)
 				.BackOffTime(TimeSpan.FromSeconds(10))
 				.BackOffRetries(2)
 				.Size(size)
 				.RefreshOnCompleted()
 				.Index(index)
-			);
-			//we set up an observer
+			);
+			//we set up an observer
 			var bulkObserver = new BulkAllObserver(
 				onError: (e) => { throw e; },
 				onCompleted: () => handle.Set(),
 				onNext: (b) => Interlocked.Increment(ref seenPages)
-			);
-			//when we subscribe the observable becomes hot
+			);
+			//when we subscribe the observable becomes hot
 			observableBulk.Subscribe(bulkObserver);
 
 			handle.WaitOne(TimeSpan.FromMinutes(5));
@@ -73,7 +73,7 @@ public void ReturnsExpectedResponse()
 			bulkObserver.TotalNumberOfRetries.Should().Be(0);
 		}
 
-		[I]
+		[I]
 		public void DisposingObservableCancelsBulkAll()
 		{
 			var index = CreateIndexName();
@@ -83,30 +83,30 @@ public void DisposingObservableCancelsBulkAll()
 			var pages = 100;
 			var seenPages = 0;
 			var numberOfDocuments = size * pages;
-			var documents = this.CreateLazyStreamOfDocuments(numberOfDocuments);
-
-			//first we setup our cold observable
+			var documents = this.CreateLazyStreamOfDocuments(numberOfDocuments);
+
+			//first we setup our cold observable
 			var observableBulk = this._client.BulkAll(documents, f => f
 				.MaxDegreeOfParallelism(8)
 				.BackOffTime(TimeSpan.FromSeconds(10))
 				.BackOffRetries(2)
 				.Size(size)
 				.RefreshOnCompleted()
 				.Index(index)
-			);
-			//we set up an observer
+			);
+			//we set up an observer
 			var bulkObserver = new BulkAllObserver(
 				onError: (e) => { throw e; },
 				onCompleted: () => handle.Set(),
 				onNext: (b) => Interlocked.Increment(ref seenPages)
-			);
-			//when we subscribe the observable becomes hot
-			observableBulk.Subscribe(bulkObserver);
-
-			//we wait N seconds to see some bulks
-			handle.WaitOne(TimeSpan.FromSeconds(3));
-			observableBulk.Dispose();
-			//we wait N seconds to give in flight request a chance to cancel
+			);
+			//when we subscribe the observable becomes hot
+			observableBulk.Subscribe(bulkObserver);
+
+			//we wait N seconds to see some bulks
+			handle.WaitOne(TimeSpan.FromSeconds(1));
+			observableBulk.Dispose();
+			//we wait N seconds to give in flight request a chance to cancel
 			handle.WaitOne(TimeSpan.FromSeconds(3));
 
 			seenPages.Should().BeLessThan(pages).And.BeGreaterThan(0);
@@ -116,7 +116,7 @@ public void DisposingObservableCancelsBulkAll()
 			bulkObserver.TotalNumberOfRetries.Should().Be(0);
 		}
 
-		[I]
+		[I]
 		public void CancelBulkAll()
 		{
 			var index = CreateIndexName();
@@ -126,9 +126,9 @@ public void CancelBulkAll()
 			var pages = 100;
 			var seenPages = 0;
 			var numberOfDocuments = size * pages;
-			var documents = this.CreateLazyStreamOfDocuments(numberOfDocuments);
-
-			//first we setup our cold observable
+			var documents = this.CreateLazyStreamOfDocuments(numberOfDocuments);
+
+			//first we setup our cold observable
 			var tokenSource = new CancellationTokenSource();
 			var observableBulk = this._client.BulkAll(documents, f => f
 				.MaxDegreeOfParallelism(8)
@@ -137,21 +137,21 @@ public void CancelBulkAll()
 				.Size(size)
 				.RefreshOnCompleted()
 				.Index(index)
-			, tokenSource.Token);
-
-			//we set up an observer
+			, tokenSource.Token);
+
+			//we set up an observer
 			var bulkObserver = new BulkAllObserver(
 				onError: (e) => { throw e; },
 				onCompleted: () => handle.Set(),
 				onNext: (b) => Interlocked.Increment(ref seenPages)
-			);
-			//when we subscribe the observable becomes hot
-			observableBulk.Subscribe(bulkObserver);
-
-			//we wait Nseconds to see some bulks
-			handle.WaitOne(TimeSpan.FromSeconds(3));
-			tokenSource.Cancel();
-			//we wait Nseconds to give in flight request a chance to cancel
+			);
+			//when we subscribe the observable becomes hot
+			observableBulk.Subscribe(bulkObserver);
+
+			//we wait Nseconds to see some bulks
+			handle.WaitOne(TimeSpan.FromSeconds(1));
+			tokenSource.Cancel();
+			//we wait Nseconds to give in flight request a chance to cancel
 			handle.WaitOne(TimeSpan.FromSeconds(3));
 
 			seenPages.Should().BeLessThan(pages).And.BeGreaterThan(0);
@@ -161,7 +161,7 @@ public void CancelBulkAll()
 			bulkObserver.TotalNumberOfRetries.Should().Be(0);
 		}
 
-		[I]
+		[I]
 		public async Task AwaitBulkAll()
 		{
 			var index = CreateIndexName();