Solr: partition changes the order.

Solr: partition changes the order. Use instead span
helena · Dec 9, 2018 · 8effc50 · 8effc50
1 parent 58c3ea5
commit 8effc50
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/solr/src/main/scala/akka/stream/alpakka/solr/SolrFlowStage.scala b/solr/src/main/scala/akka/stream/alpakka/solr/SolrFlowStage.scala
@@ -364,7 +364,7 @@ private[solr] final class SolrFlowLogic[T, C](
     def send(toSend: Seq[IncomingMessage[T, C]]): UpdateResponse = {
       val operation = toSend.head.operation
       //Just take a subset of this operation
-      val (current, remaining) = toSend.partition { m =>
+      val (current, remaining) = toSend.span { m =>
         m.operation == operation
       }
       //send this subset