Auf das zugrunde liegende ActorRef eines von Source.actorRef @ erstellten Akka-Streams zugreif
Ich versuche das @ zu benutz Source.actorRef Methode zum Erstellen eines akka.stream.scaladsl.Source Objekt. Etwas von der Form
import akka.stream.OverflowStrategy.fail
import akka.stream.scaladsl.Source
case class Weather(zip : String, temp : Double, raining : Boolean)
val weatherSource = Source.actorRef[Weather](Int.MaxValue, fail)
val sunnySource = weatherSource.filter(!_.raining)
...
Meine Frage ist:wie sende ich Daten an mein ActorRef-basiertes Quellobjekt?
Ich nahm an, dass das Senden von Nachrichten an die Quelle in etwa der Form entspricht
//does not compile
weatherSource ! Weather("90210", 72.0, false)
weatherSource ! Weather("02139", 32.0, true)
AberweatherSource hat kein! operator odertell Methode
DasDokumentatio beschreibt die Verwendung von Source.actorRef nicht zu genau, sondern sagt nur, dass Sie ...
ielen Dank für Ihre Bewertu