Upgraded scala-libraries-2 also into 2.13 version

Author: yadavan88

build.sbt

@@ -238,7 +238,6 @@ val sparkVersion = "3.2.1"
 
 lazy val scala_libraries_2 = (project in file("scala-libraries-2"))
   .settings(
-    scalaVersion := "2.12.15",
     name := "scala-libraries",
     libraryDependencies += "org.scalatest" %% "scalatest" % "3.1.2" % Test,
     libraryDependencies ++= Seq(
@@ -252,16 +251,12 @@ lazy val scala_libraries_2 = (project in file("scala-libraries-2"))
       "com.beachape" %% "enumeratum" % "1.7.0"
     ),
     libraryDependencies ++= Seq(
-      "com.typesafe.play" %% "play-slick" % "5.0.0",
+      "com.typesafe.play" %% "play-slick" % "5.1.0",
       "org.postgresql" % "postgresql" % "42.2.12"
     ),
     libraryDependencies ++= Seq(
       "io.monix" %% "monix" % monixVersion
     ),
-    libraryDependencies ++= Seq(
-      "org.apache.spark" %% "spark-core" % sparkVersion,
-      "org.apache.spark" %% "spark-sql" % sparkVersion
-    ),
     dependencyOverrides := Seq(
       "com.typesafe.akka" %% "akka-protobuf-v3" % "2.6.16",
       "com.typesafe.akka" %% "akka-stream" % "2.6.16",
@@ -331,10 +326,6 @@ lazy val scala_libraries_4 = (project in file("scala-libraries-4"))
       "org.scala-lang" % "scala-reflect" % scalaVersion.value % Provided,
       "org.tpolecat" %% "skunk-core" % "0.3.2"
     ),
-    libraryDependencies ++= Seq(
-      "org.apache.spark" %% "spark-core" % sparkVersion,
-      "org.apache.spark" %% "spark-sql" % sparkVersion
-    ),
     scalacOptions += "-Xasync"
   )
 
@@ -413,6 +404,8 @@ lazy val scala212 = (project in file("scala212"))
     scalaVersion := "2.12.17",
     name := "scala212",
     libraryDependencies ++= Seq(
-      scalaTest
+      scalaTest,
+      "org.apache.spark" %% "spark-core" % sparkVersion,
+      "org.apache.spark" %% "spark-sql" % sparkVersion
     )
   )

scala-libraries-2/src/test/scala/com/baeldung/akka/Tests.scala

@@ -72,7 +72,7 @@ class GreeterTest extends TestService {
   sender ! Greeter.GreetingRequest(greeting, probe.ref)
   probe.expectMessage(Greeter.GreetingResponse(greeting))
   // no other message should be received by the greeter actor
-  probe.expectNoMessage(50 millis)
+  probe.expectNoMessage(50.millis)
 }
 
 class TrafficLightTest extends TestService {
@@ -83,29 +83,29 @@ class TrafficLightTest extends TestService {
   // ensure that initial state is RED
   sender ! TrafficLight.SignalCommand.GetSignal(probe.ref)
   probe.expectMessage(TrafficLight.CurrentSignal(TrafficLight.Signal.RED))
-  probe.expectNoMessage(50 millis)
+  probe.expectNoMessage(50.millis)
 
 
   // now try to change signal
   sender ! TrafficLight.SignalCommand.ChangeSignal(probe.ref)
   probe.expectMessage(TrafficLight.CurrentSignal(TrafficLight.Signal.YELLOW))
   // ensure no other message is received
-  probe.expectNoMessage(50 millis)
+  probe.expectNoMessage(50.millis)
 
   // ensure that the state is preserved
   sender ! TrafficLight.SignalCommand.ChangeSignal(probe.ref)
   probe.expectMessage(TrafficLight.CurrentSignal(TrafficLight.Signal.GREEN))
-  probe.expectNoMessage(50 millis)
+  probe.expectNoMessage(50.millis)
   //ensure that the state is preserved
   sender ! TrafficLight.SignalCommand.ChangeSignal(probe.ref)
   probe.expectMessage(TrafficLight.CurrentSignal(TrafficLight.Signal.RED))
-  probe.expectNoMessage(50 millis)
+  probe.expectNoMessage(50.millis)
 }
 
 class TrafficLightTestFut extends TestService {
   import scala.concurrent.duration._
   val sender = testKit.spawn(TrafficLight(), "traffic")
-  val duration = 300 millis
+  val duration = 300.millis
   implicit val timeout = Timeout(duration)
 
   val signalFut =  sender.ask(replyTo =>TrafficLight.SignalCommand.GetSignal(replyTo))

scala-test/src/test/scala/com/baeldung/scala/scalatest/mockito/InventoryServiceTest.scala

@@ -43,8 +43,10 @@ class InventoryServiceTest extends AnyWordSpec with MockitoSugar with ScalaFutur
       val service = new InventoryService(dao, mockProducer, mockLogger)
       when(dao.saveAsync(any[InventoryTransaction])).thenReturn(Future.successful(txn))
       doNothing().when(mockProducer).publish(txn)
-      service.saveAndPublish(txn)
-      verify(mockProducer, times(1)).publish(any[InventoryTransaction])
+      val result = service.saveAndPublish(txn)
+      whenReady(result){ _ =>
+        verify(mockProducer, times(1)).publish(any[InventoryTransaction])
+      }
     }
 
     "save and NOT publish to kafka for non chocolate inventory" in {