anchor.diff:              let txEntry = TransactionLog.T.Create(txId, id)
               use stream = memoryManager.GetStream()
               TransactionLog.serializer (stream, txEntry)
  +            s.ShardWriters.[shardNo].TxWriter.Append(stream.ToArray(), s.ShardWriters.[shardNo].Generation.Value)
               s.ShardWriters.[shardNo] |> ShardWriter.deleteDocument id (s.GetSchemaName(Constants.IdField))
           }
       
  
positive.code:                         while fileStream.Position <> fileStream.Length do
                              yield msgPackSerializer.Unpack(fileStream)
                      }
                  with _ -> Seq.empty
              else Seq.empty
          
          /// Append a new entry to TxLog        
  
negative.code:             // introduce blank commits in case there are no logs to replay.
              shardWriter |> ShardWriter.refresh
              shardWriter.Status <- ShardWriter.Status.Online
          indexWriter.ShardWriters |> Array.Parallel.iter replayShardTransaction
      
      /// Create a new index instance
      let create (settings : IndexSetting.T) = 
  