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''")
-        }
 }

Reply via email to