Add missing type declaration to keep source uniformity

joneyin · Jul 10, 2018 · d3ea293 · d3ea293
1 parent acf6ba6
commit d3ea293
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/elasticsearch/src/main/scala/akka/stream/alpakka/elasticsearch/ElasticsearchFlowStage.scala b/elasticsearch/src/main/scala/akka/stream/alpakka/elasticsearch/ElasticsearchFlowStage.scala
@@ -69,7 +69,7 @@ final case class IncomingMessage[T, C](id: Option[String],
   def withVersion(version: Long): IncomingMessage[T, C] =
     this.copy(version = Option(version))
 
-  def withIndexName(indexName: String) =
+  def withIndexName(indexName: String): IncomingMessage[T, C] =
     this.copy(indexName = Option(indexName))
 }