Update PekkoDiscoveryNameResolver.scala

apache · Nov 3, 2024 · 6dbbbb4 · 6dbbbb4
1 parent 1028b97
commit 6dbbbb4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/runtime/src/main/scala/org/apache/pekko/grpc/internal/PekkoDiscoveryNameResolver.scala b/runtime/src/main/scala/org/apache/pekko/grpc/internal/PekkoDiscoveryNameResolver.scala
@@ -52,7 +52,8 @@ class PekkoDiscoveryNameResolver(
   def lookup(listener: Listener): Unit = {
     import scala.concurrent.Await
     try {
-      val result = Await.result(discovery.lookup(Lookup(serviceName, portName, protocol), resolveTimeout), resolveTimeout)
+      val result =
+        Await.result(discovery.lookup(Lookup(serviceName, portName, protocol), resolveTimeout), resolveTimeout)
       listener.onAddresses(addresses(result.addresses), Attributes.EMPTY)
     } catch {
       case e: Throwable =>