[Minor] Code refactored (lagom#504)

* Minor code refactoring done * minor code refactoring * Reverted a missing parantheses.
Empia · Feb 20, 2017 · 18af933 · 18af933
1 parent 36ffc88
commit 18af933
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 8 deletions.
diff --git a/...om/lightbend/lagom/internal/scaladsl/persistence/cassandra/CassandraReadSideHandler.scala b/...om/lightbend/lagom/internal/scaladsl/persistence/cassandra/CassandraReadSideHandler.scala
@@ -90,7 +90,9 @@ private[cassandra] final class CassandraAutoReadSideHandler[Event <: AggregateEv
 
   override protected def invoke(handler: Handler[Event], element: EventStreamElement[Event]): Future[immutable.Seq[BoundStatement]] = {
     for {
-      statements <- (handler.asInstanceOf[EventStreamElement[Event] => Future[immutable.Seq[BoundStatement]]].apply(element))
+      statements <- handler
+        .asInstanceOf[EventStreamElement[Event] => Future[immutable.Seq[BoundStatement]]]
+        .apply(element)
     } yield statements :+ offsetDao.bindSaveOffset(element.offset)
   }
 

diff --git a/...c/main/scala/com/lightbend/lagom/internal/javadsl/persistence/PersistentEntityActor.scala b/...c/main/scala/com/lightbend/lagom/internal/javadsl/persistence/PersistentEntityActor.scala
@@ -92,16 +92,16 @@ private[lagom] class PersistentEntityActor[C, E, S](
 
     def initEmpty(): Unit =
       if (!initialized) {
-        val inital = entity.initialBehavior(Optional.empty[S])
-        entity.internalSetCurrentBehavior(inital)
+        val initial = entity.initialBehavior(Optional.empty[S])
+        entity.internalSetCurrentBehavior(initial)
         initialized = true
       }
 
     {
       case SnapshotOffer(_, snapshot) =>
         if (!initialized) {
-          val inital = entity.initialBehavior(Optional.ofNullable(snapshot.asInstanceOf[S]))
-          entity.internalSetCurrentBehavior(inital)
+          val initial = entity.initialBehavior(Optional.ofNullable(snapshot.asInstanceOf[S]))
+          entity.internalSetCurrentBehavior(initial)
           initialized = true
         }
 

diff --git a/...vadsl/src/main/scala/com/lightbend/lagom/internal/javadsl/persistence/ReadSideActor.scala b/...vadsl/src/main/scala/com/lightbend/lagom/internal/javadsl/persistence/ReadSideActor.scala
@@ -70,7 +70,7 @@ private[lagom] class ReadSideActor[Event <: AggregateEvent[Event]](
 
     case Done =>
       val handler = processorFactory().buildHandler()
-      handler.prepare(tag).toScala.map(Start(_)) pipeTo self
+      handler.prepare(tag).toScala.map(Start) pipeTo self
       context become active(handler, tag)
 
     case Status.Failure(e) =>

diff --git a/pubsub/javadsl/src/main/scala/com/lightbend/lagom/javadsl/pubsub/PubSubRef.scala b/pubsub/javadsl/src/main/scala/com/lightbend/lagom/javadsl/pubsub/PubSubRef.scala
@@ -115,6 +115,6 @@ final class PubSubRef[T](val topic: TopicId[T], mediator: ActorRef, system: Acto
   protected def writeReplace(): AnyRef =
     throw new NotSerializableException(s"${getClass.getName} is not serializable. Send the entityId instead.")
 
-  override def toString(): String = s"PubSubRef($topic)"
+  override def toString: String = s"PubSubRef($topic)"
 
 }
diff --git a/...caladsl/src/multi-jvm/scala/com/lightbend/lagom/scaladsl/pubsub/ClusteredPubSubSpec.scala b/...caladsl/src/multi-jvm/scala/com/lightbend/lagom/scaladsl/pubsub/ClusteredPubSubSpec.scala
@@ -113,7 +113,7 @@ class ClusteredPubSubSpec extends MultiNodeSpec(ClusteredPubSubConfig)
         enterBarrier("subscription-established-2")
 
         ref2.publisher.runWith(
-          Source(List("a", "b", "c", "d", "e").map(Notification(_))))
+          Source(List("a", "b", "c", "d", "e").map(Notification)))
       }
 
       enterBarrier("after-2")