fixes #87

Author: anshooarora

extentreports-dotnet-core/Core/ReportObservable.cs

@@ -257,7 +257,7 @@ private void CollectRunInfo()
 
                 foreach (var test in _testList)
                 {
-                    test.End();
+                    EndTest(test);
                     CopyContextInfoToObservable(test);
                 }
             }

extentreports-dotnet-core/Core/ReportStatusStats.cs

@@ -218,7 +218,7 @@ public ReportStatusStats(AnalysisStrategy strategy) : this()
         public void Refresh(List<Test> testList)
         {
             Reset();
-            _testList = testList;
+            _testList = testList.ToList();
             RefreshStats();
         }
 
@@ -304,7 +304,7 @@ private void UpdateGroupCountsBDD(Test test)
                             if (grandchild.BehaviorDrivenType.GetType() == typeof(Scenario))
                             {
                                 IncrementItemCountByStatus(ItemLevel.Child, grandchild.Status);
-                                grandchild.NodeContext.All().ToList()
+                                grandchild.NodeContext.All()
                                     .ForEach(x => IncrementItemCountByStatus(ItemLevel.GrandChild, x.Status));
                             }
                             else
@@ -335,7 +335,7 @@ private void UpdateGroupCountsTestStrategyChildren(Test test)
         {
             if (test.HasChildren)
             {
-                foreach (var node in test.NodeContext.All().ToList())
+                foreach (var node in test.NodeContext.All())
                 {
                     if (node.HasChildren)
                     {

extentreports-dotnet-core/Model/AbstractStructure.cs

@@ -8,7 +8,7 @@ namespace AventStack.ExtentReports.Model
     [Serializable]
     public class GenericStructure<T>
     {
-        private BlockingCollection<T> _list
+        private List<T> _list
         {
             get
             {
@@ -22,64 +22,88 @@ private BlockingCollection<T> _list
                 }
             }
         }
-        private BlockingCollection<T> _listv = new BlockingCollection<T>();
+        private List<T> _listv = new List<T>();
 
         private readonly object _syncLock = new object();
 
         public bool IsEmpty
         {
             get
             {
-                return Count == 0;
+                lock (_syncLock)
+                {
+                    return Count == 0;
+                }
             }
         }
 
         public int Count
         {
             get
             {
-                return _list == null ? 0 : _list.Count;
+                lock (_syncLock)
+                {
+                    return _list == null ? 0 : _list.Count;
+                }
             }
         }
 
         public bool Contains(T t)
         {
-            return _list.Contains(t);
+            lock (_syncLock)
+            {
+                return _list.Contains(t);
+            }
         }
 
         public void Add(T t)
         {
-            _list.Add(t);
+            lock (_syncLock)
+            {
+                _list.Add(t);
+            }
         }
 
         public void Remove(T t)
         {
-            _list.ToList().Remove(t);
+            lock (_syncLock)
+            {
+                _list.ToList().Remove(t);
+            }
         }
 
         public T Get(int index)
         {
-            return _list.ElementAt(index);
+            lock (_syncLock)
+            {
+                return _list.ElementAt(index);
+            }
         }
 
         public T FirstOrDefault()
         {
-            return _list.Count == 0 ? default(T) : Get(0);
+            lock (_syncLock)
+            {
+                return _list.Count == 0 ? default(T) : Get(0);
+            }
         }
 
         public T LastOrDefault()
         {
-            return _list.Count == 0 ? default(T) : Get(_list.Count - 1);
+            lock (_syncLock)
+            {
+                return _list.Count == 0 ? default(T) : Get(_list.Count - 1);
+            }
         }
 
-        public BlockingCollection<T> All()
+        public List<T> All()
         {
             return _list;
         }
 
         public TIterator<T> GetEnumerator()
         {
-            return new TIterator<T>(_list.GetConsumingEnumerable().ToList());
+            return new TIterator<T>(_list);
         }
     }
 }

extentreports-dotnet-core/Service/TestRemoveService.cs

@@ -30,7 +30,7 @@ private static void FindAndRemoveTest(List<Test> testList, Test test)
             {
                 if (_removed)
                     return;
-                FindAndRemoveTest(t.NodeContext.All().ToList(), test);
+                FindAndRemoveTest(t.NodeContext.All(), test);
             }          
         }