Estoy tratando de usar elSource.actorRef método para crear unakka.stream.scaladsl.Source objeto. Algo de la forma

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)
...

Mi pregunta es:¿Cómo envío datos a mi objeto Source basado en ActorRef??

Asumí que enviar mensajes a la Fuente era algo así como la forma

//does not compile
weatherSource ! Weather("90210", 72.0, false)
weatherSource ! Weather("02139", 32.0, true)

PeroweatherSource no tiene un! operador otell método.

losdocumentación no es demasiado descriptivo sobre cómo usar Source.actorRef, solo dice que puedes ...

Gracias de antemano por su revisión y respuesta.