1 files changed, 82 insertions, 0 deletions
diff --git a/src/core/Index/DocFieldConsumersPerThread.cs b/src/core/Index/DocFieldConsumersPerThread.cs
new file mode 100644
index 0000000..7098966
--- /dev/null
+++ b/src/core/Index/DocFieldConsumersPerThread.cs
@@ -0,0 +1,82 @@
+/* 
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+using System;
+
+namespace Lucene.Net.Index
+{
+	
+	sealed class DocFieldConsumersPerThread:DocFieldConsumerPerThread
+	{
+		
+		internal DocFieldConsumerPerThread one;
+		internal DocFieldConsumerPerThread two;
+		internal DocFieldConsumers parent;
+		internal DocumentsWriter.DocState docState;
+		
+		public DocFieldConsumersPerThread(DocFieldProcessorPerThread docFieldProcessorPerThread, DocFieldConsumers parent, DocFieldConsumerPerThread one, DocFieldConsumerPerThread two)
+		{
+			this.parent = parent;
+			this.one = one;
+			this.two = two;
+			docState = docFieldProcessorPerThread.docState;
+		}
+		
+		public override void  StartDocument()
+		{
+			one.StartDocument();
+			two.StartDocument();
+		}
+		
+		public override void  Abort()
+		{
+			try
+			{
+				one.Abort();
+			}
+			finally
+			{
+				two.Abort();
+			}
+		}
+		
+		public override DocumentsWriter.DocWriter FinishDocument()
+		{
+			DocumentsWriter.DocWriter oneDoc = one.FinishDocument();
+			DocumentsWriter.DocWriter twoDoc = two.FinishDocument();
+			if (oneDoc == null)
+				return twoDoc;
+			else if (twoDoc == null)
+				return oneDoc;
+			else
+			{
+				DocFieldConsumers.PerDoc both = parent.GetPerDoc();
+				both.docID = docState.docID;
+				System.Diagnostics.Debug.Assert(oneDoc.docID == docState.docID);
+				System.Diagnostics.Debug.Assert(twoDoc.docID == docState.docID);
+				both.one = oneDoc;
+				both.two = twoDoc;
+				return both;
+			}
+		}
+		
+		public override DocFieldConsumerPerField AddField(FieldInfo fi)
+		{
+			return new DocFieldConsumersPerField(this, one.AddField(fi), two.AddField(fi));
+		}
+	}
+}
+\ No newline at end of file