This is an automated email from the ASF dual-hosted git repository.
sergeykamov pushed a commit to branch NLPCRAFT-41
in repository https://gitbox.apache.org/repos/asf/incubator-nlpcraft.git
The following commit(s) were added to refs/heads/NLPCRAFT-41 by this push:
new 2297c9c WIP.
2297c9c is described below
commit 2297c9ccfe1ce254ffeba79bce743fc91d034289
Author: Sergey Kamov <[email protected]>
AuthorDate: Fri Sep 11 13:55:24 2020 +0300
WIP.
---
.../nlpcraft/server/probe/NCProbeManager.scala | 30 ----------------------
1 file changed, 30 deletions(-)
diff --git
a/nlpcraft/src/main/scala/org/apache/nlpcraft/server/probe/NCProbeManager.scala
b/nlpcraft/src/main/scala/org/apache/nlpcraft/server/probe/NCProbeManager.scala
index 444ccc1..fe4dadc 100644
---
a/nlpcraft/src/main/scala/org/apache/nlpcraft/server/probe/NCProbeManager.scala
+++
b/nlpcraft/src/main/scala/org/apache/nlpcraft/server/probe/NCProbeManager.scala
@@ -1026,34 +1026,4 @@ object NCProbeManager extends NCService {
case None ⇒ throw new NCE(s"Probe not found for model:
'$mdlId''")
}
}
-
- /**
- *
- * @param parent
- * @param mdlId
- * @param promises
- * @param msgId
- * @param msgParams
- */
- private def probePromise[T](
- parent: Span,
- mdlId: String,
- promises: ConcurrentHashMap[String, Promise[T]],
- msgId: String,
- msgParams: (String, Serializable)*
- ): Future[T] =
- getProbeForModelId(mdlId) match {
- case Some(probe) ⇒
- val msg = NCProbeMessage(msgId, msgParams:_*)
-
- val promise = Promise[T]()
-
- promises.put(msg.getGuid, promise)
-
- sendToProbe(probe.probeKey, msg, parent)
-
- promise.future
-
- case None ⇒ throw new NCE(s"Probe not found for model: '$mdlId''")
- }
}