small refactor changes 💄

jpzk · Aug 10, 2018 · d218462 · d218462
1 parent bd91d46
commit d218462
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/src/main/scala/MockedStreams.scala b/src/main/scala/MockedStreams.scala
@@ -103,10 +103,7 @@ object MockedStreams {
       props.put(StreamsConfig.APPLICATION_ID_CONFIG, s"mocked-${UUID.randomUUID().toString}")
       props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092")
       props.putAll(configuration)
-
-      val t: () => Topology = topology.getOrElse(throw new NoTopologySpecified)
-
-      new Driver(t(), props)
+      new Driver(topology.getOrElse(throw new NoTopologySpecified)(), props)
     }
 
     private def produce(driver: Driver): Unit =