Suchergebnisse für Anfrage "akka"
Holen Sie sich den gesamten HttpResponse-Body als String mit Akka-Streams HTTP
Ich versuche zu verstehen, wie man das neue @ benutakka.http Bibliothek. Ich möchte eine http-Anfrage an einen Server senden und den gesamten Antworttext als einzelnen String lesen, um ein @ zu erzeugeSource[String,?]. Hier ist die beste ...
Warum funktioniert Spark-Broadcast nicht gut, wenn ich die App "Erweitert" verwende?
Der erste Code löst eine Nullzeigerausnahme aus. object TryBroadcast extends App{ val conf = new SparkConf().setAppName("o_o") val sc = new SparkContext(conf) val sample = sc.parallelize(1 to 1024) val bro = sc.broadcast(6666) val broSample = ...
Wie funktioniert async Action api in Play Framework 2.2.x für Scala?
Ich habe versucht, eine asynchrone API zu erstellen. Die Antwort zeigt jedoch die sequentielle Ausführung. Schritte: Öffnen Sie die URL in zwei Tabs aus Chrom. Und schlag sie schnell nacheinander. URL ex: -localhost:9000/getStar. Aber das ...
Unterschied zwischen Fallklasse und Fallobjekt?
Ich lerne Scala und Akka und habe kürzlich nach einem @ gesuchLösun [https://stackoverflow.com/questions/22770927/waiting-for-multiple-results-in-akka] , Ich habe so etwas wie @ gefund case class TotalTaxResult(taxAmount:Double) case object ...
Wie führt spray.routing.HttpService Versandanforderungen durch?
Haftungsausschluss: Ich habe noch keine Scala-Erfahrung, daher ist meine Frage mit sehr grundlegenden Fragen verbunden. Betrachten Sie das folgende Beispiel (es ist möglicherweise unvollständig): import akka.actor.{ActorSystem, Props} import ...
Custom Supervision.Decider fängt keine Ausnahme ab, die von ActorPublisher @ erzeugt wur
Ich baue eine Bibliothek auf, die von Drittanbietern verwendet wird. Bei einer meiner Methoden gebe ich @ zurüStream[Item] das asynchron aus dem Ergebnis eines paginierten REST-API-Aufrufs generiert wird. Ich verwende meine Änderung von ...
akka HttpResponse Körper als String scala lesen
So habe ich eine Funktion mit dieser Signatur (akka.http.model.HttpResponse): def apply(query: Seq[(String, String)], accept: String): HttpResponseIch erhalte einfach einen Wert in einem Test wie: val resp = TagAPI(Seq.empty[(String, String)], ...
akka-http: Wie man Antwort-Header setzt
Ich habe eine Route wie folgt: val route = { logRequestResult("user-service") { pathPrefix("user") { get { respondWithHeader(RawHeader("Content-Type", "application/json")) { parameters("firstName".?, "lastName".?).as(Name) { name => ...
Wie werden Akka HTTP-Client-Anforderungen protokolliert?
Ich muss akka http-Client-Anforderungen sowie deren Antworten protokollieren. Es scheint zwar einen Hinweis auf eine API für die Protokollierung dieser Anforderungen zu geben, es gibt jedoch keine eindeutige Dokumentation, wie dies erfolgen soll. ...
Welchen ThreadPool in Java soll ich verwenden?
Es gibt eine Menge Aufgaben. Jede Aufgabe gehört zu einer einzelnen Gruppe. Die Anforderung ist, dass jede Gruppe von Aufgaben wie in einem einzelnen Thread seriell ausgeführt wird und der Durchsatz in einer Umgebung mit mehreren Kernen (oder ...