Changes API: How to subscribe to bulk insert operation changes?

ForBulkInsert method can be used to acquire notifications for bulk insert operations.

Syntax

IObservableWithTask<BulkInsertChangeNotification>
	ForBulkInsert(Guid operationId);

Example

using (BulkInsertOperation bulkInsert = store.BulkInsert())
{
	IDisposable subscription = store
		.Changes()
		.ForBulkInsert(bulkInsert.OperationId)
		.Subscribe(change =>
		{
			switch (change.Type)
			{
				case DocumentChangeTypes.BulkInsertStarted:
					// do something
					break;
				case DocumentChangeTypes.BulkInsertEnded:
					// do something
					break;
				case DocumentChangeTypes.BulkInsertError:
					// do something
					break;
			}
		});

	try
	{
		for (int i = 0; i < 1000 * 1000; i++)
		{
			bulkInsert.Store(new Employee
			{
				FirstName = "FirstName #" + i,
				LastName = "LastName #" + i
			});
		}
	}
	finally
	{
		if (subscription != null)
			subscription.Dispose();
	}
}

Remarks