A partial function is a function that is valid for only a subset of values of those types you might pass in to it. For example: val root: PartialFunction[Double,Double] = { case d if (d >= 0) => math.sqrt(d) } scala> root.isDefinedAt(-1) res0: Boolean = false scala> root(3) res1: Double = 1.7320508075688772 This is useful … Read more
You should scope your concurrency appropriately using structured concurrency. Your coroutines can leak if you don’t do this. In your case, scoping them to the processing of a single message seems appropriate. Here’s an example: /* I don’t know Kafka, but let’s pretend this function gets * called when you receive a new message */ … Read more
If you include the parentheses in the definition you can optionally omit them when you call the method. If you omit them in the definition you can’t use them when you call the method. scala> def foo() {} foo: ()Unit scala> def bar {} bar: Unit scala> foo scala> bar() <console>:12: error: Unit does not … Read more