Merge branch 'issue-335' into main-master

liujiyuan · Apr 1, 2014 · 828bb20 · 828bb20
2 parents 3a79547 + 12a1abd
commit 828bb20
Showing 1 changed file with 3 additions and 21 deletions.
diff --git a/src/NEventStore/OptimisticEventStore.cs b/src/NEventStore/OptimisticEventStore.cs
@@ -2,7 +2,6 @@ namespace NEventStore
 {
     using System;
     using System.Collections.Generic;
-    using System.Linq;
     using NEventStore.Logging;
     using NEventStore.Persistence;
 
@@ -25,26 +24,9 @@ public OptimisticEventStore(IPersistStreams persistence, IEnumerable<IPipelineHo
             _persistence = new PipelineHooksAwarePersistanceDecorator(persistence, _pipelineHooks);
         }
 
-        public virtual IEnumerable<ICommit> GetFrom(string bucketId, string streamId, int minRevision, int maxRevision)
-        {
-            foreach (var commit in _persistence.GetFrom(bucketId, streamId, minRevision, maxRevision))
-            {
-                ICommit filtered = commit;
-                foreach (var hook in _pipelineHooks.Where(x => (filtered = x.Select(filtered)) == null))
-                {
-                    Logger.Info(Resources.PipelineHookSkippedCommit, hook.GetType(), commit.CommitId);
-                    break;
-                }
-
-                if (filtered == null)
-                {
-                    Logger.Info(Resources.PipelineHookFilteredCommit);
-                }
-                else
-                {
-                    yield return filtered;
-                }
-            }
+        public virtual IEnumerable<ICommit> GetFrom(string bucketId, string streamId, int minRevision, int maxRevision)
+        {
+            return _persistence.GetFrom(bucketId, streamId, minRevision, maxRevision);
         }
 
         public virtual ICommit Commit(CommitAttempt attempt)