From bddbe4a37fae594adb1a475686b97e9aa54ec9cb Mon Sep 17 00:00:00 2001 From: Peter Vlugter Date: Thu, 3 Dec 2020 13:43:12 +1300 Subject: [PATCH] Fix proto descriptor extract service --- .../main/scala/io/cloudstate/proxy/EntityDiscoveryManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/proxy/core/src/main/scala/io/cloudstate/proxy/EntityDiscoveryManager.scala b/proxy/core/src/main/scala/io/cloudstate/proxy/EntityDiscoveryManager.scala index a519143d3..b72ca9513 100644 --- a/proxy/core/src/main/scala/io/cloudstate/proxy/EntityDiscoveryManager.scala +++ b/proxy/core/src/main/scala/io/cloudstate/proxy/EntityDiscoveryManager.scala @@ -255,7 +255,7 @@ class EntityDiscoveryManager(config: EntityDiscoveryManager.Configuration)( private[this] final def extractService(serviceName: String, descriptor: FileDescriptor): Option[ServiceDescriptor] = { val (pkg, name) = Names.splitPrev(serviceName) - Some(descriptor).filter(_.getPackage == pkg).map(_.findServiceByName(name)) + if (descriptor.getPackage == pkg) Option(descriptor.findServiceByName(name)) else None } private[this] final def binding(eventManager: Option[RunnableGraph[Future[Done]]]): Receive = {