Accessing the underlying ActorRef of an akka stream Source created by Source.actorRef

by

You need a Flow:

  import akka.stream.OverflowStrategy.fail
  import akka.stream.scaladsl.Source
  import akka.stream.scaladsl.{Sink, Flow}

  case class Weather(zip : String, temp : Double, raining : Boolean)

  val weatherSource = Source.actorRef[Weather](Int.MaxValue, fail)

  val sunnySource = weatherSource.filter(!_.raining)

  val ref = Flow[Weather]
    .to(Sink.ignore)
    .runWith(sunnySource)

  ref ! Weather("02139", 32.0, true)

Remember this is all experimental and may change!

More Related Contents:

  1. How to create a Source that can receive elements later via a method call?
  2. sender inside a future
  3. No configuration setting found for key ‘akka.version’
  4. Akka Kill vs. Stop vs. Poison Pill?
  5. How to restrict actor messages to specific types?
  6. Akka-Stream implementation slower than single threaded implementation
  7. Apache Spark – Scala – ReduceByKey – with keys repeating up to twice only
  8. What is the difference between a var and val definition in Scala?
  9. What is the apply function in Scala?
  10. How do I apply the enrich-my-library pattern to Scala collections?
  11. How to import build.gradle into IntelliJ
  12. How to model type-safe enum types?
  13. Scala: List[Future] to Future[List] disregarding failed futures
  14. Scala 2.8 collections design tutorial
  15. Scala classOf for type parameter
  16. val and object inside a scala class?
  17. Implicit keyword before a parameter in anonymous function in Scala
  18. What are possible reasons for receiving TimeoutException: Futures timed out after [n seconds] when working with Spark [duplicate]
  19. Parsing multiline records in Scala
  20. In Scala 2, type inference fails on Set made with .toSet?
  21. Explanation of fold method of spark RDD
  23. Get a TypeTag from a Type?
  24. How to write a proper null-safe coalescing operator in scala?
  25. Can’t access Parent’s Members while dealing with Macro Annotations
  26. Why is join not possible after show operator?
  27. Install sbt on ubuntu [closed]
  28. Should I use the final modifier when declaring case classes?
  29. Scala equivalent of Java’s Number
  30. Difference between two rows in Spark dataframe

Leave a Comment