empty and identity also in EventProducerPushDestination Transformation

akka-projection-grpc/src/main/scala/akka/projection/grpc/consumer/javadsl/EventProducerPushDestination.scala

@@ -107,8 +107,12 @@ final class EventProducerPushDestination private (
   /**
    * @param transformation A transformation to use for all events.
    */
-  def withTransformation(transformation: Transformation): EventProducerPushDestination =
+  def withTransformation(transformation: Transformation): EventProducerPushDestination = {
+    require(
+      transformation ne Transformation.empty,
+      s"Transformation must not be empty. Use Transformation.identity to pass through each event as is.")
     copy(transformationForOrigin = (_, _) => transformation)
+  }
 
   /**
    * @param transformation A function to create a transformation from the origin id and request metadata

akka-projection-grpc/src/main/scala/akka/projection/grpc/consumer/javadsl/Transformation.scala

@@ -16,7 +16,18 @@ import scala.compat.java8.OptionConverters._
 import scala.reflect.ClassTag
 
 object Transformation {
-  val empty = new Transformation(scaladsl.EventProducerPushDestination.Transformation.empty)
+
+  /**
+   * Starting point for building `Transformation`. Registrations of actual transformations must
+   * be added. Use [[Transformation.identity]] to pass through each event as is.
+   */
+  val empty: Transformation = new Transformation(scaladsl.EventProducerPushDestination.Transformation.empty)
+
+  /**
+   * No transformation. Pass through each event as is.
+   */
+  val identity: Transformation =
+    new Transformation(scaladsl.EventProducerPushDestination.Transformation.identity)
 }
 
 /**

akka-projection-grpc/src/main/scala/akka/projection/grpc/consumer/scaladsl/EventProducerPushDestination.scala

@@ -47,15 +47,31 @@ object EventProducerPushDestination {
     new EventProducerPushDestination(
       None,
       acceptedStreamId,
-      (_, _) => Transformation.empty,
+      (_, _) => Transformation.identity,
       None,
       immutable.Seq.empty,
       protobufDescriptors,
       EventProducerPushDestinationSettings(system))
 
   @ApiMayChange
   object Transformation {
-    val empty: Transformation = new Transformation(Map.empty, Predef.identity)
+
+    /**
+     * Starting point for building `Transformation`. Registrations of actual transformations must
+     * be added. Use [[Transformation.identity]] to pass through each event as is.
+     */
+    val empty: Transformation = new Transformation(
+      typedMappers = Map.empty,
+      untypedMappers = envelope =>
+        throw new IllegalArgumentException(
+          s"Missing transformation for event [${envelope.eventOption.map(_.getClass).getOrElse("")}]. " +
+          "Use Transformation.identity to pass through each event as is."))
+
+    /**
+     * No transformation. Pass through each event as is.
+     */
+    val identity: Transformation =
+      new Transformation(Map.empty, Predef.identity)
   }
 
   /**
@@ -200,8 +216,12 @@ final class EventProducerPushDestination private[akka] (
   /**
    * @param transformation A transformation to use for all events.
    */
-  def withTransformation(transformation: Transformation): EventProducerPushDestination =
+  def withTransformation(transformation: Transformation): EventProducerPushDestination = {
+    require(
+      transformation ne Transformation.empty,
+      s"Transformation must not be empty. Use Transformation.identity to pass through each event as is.")
     copy(transformationForOrigin = (_, _) => transformation)
+  }
 
   /**
    * @param transformation A function to create a transformation from the origin id and request metadata

akka-projection-grpc/src/main/scala/akka/projection/grpc/producer/javadsl/Transformation.scala

@@ -25,6 +25,11 @@ trait Mapper[A, B] {
 
 @ApiMayChange
 object Transformation {
+
+  /**
+   * Starting point for building `Transformation`. Registrations of actual transformations must
+   * be added. Use [[Transformation.identity]] to pass through each event as is.
+   */
   val empty: Transformation = new Transformation(scaladsl.EventProducer.Transformation.empty)
 
   /**

akka-projection-grpc/src/main/scala/akka/projection/grpc/producer/scaladsl/EventProducer.scala

@@ -105,12 +105,16 @@ object EventProducer {
   @ApiMayChange
   object Transformation {
 
+    /**
+     * Starting point for building `Transformation`. Registrations of actual transformations must
+     * be added. Use [[Transformation.identity]] to pass through each event as is.
+     */
     val empty: Transformation = new Transformation(
       mappers = Map.empty,
       orElse = envelope =>
         Future.failed(
           new IllegalArgumentException(
-            s"Missing transformation for event [${envelope.event.getClass}]. " +
+            s"Missing transformation for event [${envelope.eventOption.map(_.getClass).getOrElse("")}]. " +
             "Use Transformation.identity to pass through each event as is.")))
 
     /**

docs/src/main/paradox/grpc-producer-push.md

@@ -80,6 +80,8 @@ defines a single transformation to use for all producers, while @apidoc[EventPro
 is invoked with an origin id for the producer and additional metadata specified when setting up the producer and can provide
 transformations based on those.
 
+Use  @scala[`Transformation.identity`]@java[`Transformation.identity()`] to pass through each event as is.
+
 The payload transformation also allows for arbitrary filtering logic, returning a @scala[None]@java[Optional.empty()] marks
 the event as filtered and avoids storing the payload in the consumer journal.