I see that Oleh Dokuka, from Project Reactor (missing disclaimer there), posted an answer already, however much of its assumptions about Akka Streams and Reactive Streams are incorrect, so allow me to clarify below. Disclaimer: I participated in Reactive Streams since it’s early days, and authored most of its Technology Compatibility Kit. I also maintain … Read more
As of version 2.x you achieve this with the following code: import akka.stream.scaladsl.StreamConverters … val inputStream: InputStream = entity.dataBytes .runWith( StreamConverters.asInputStream(FiniteDuration(3, TimeUnit.SECONDS)) ) See: http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0.1/scala/migration-guide-1.0-2.x-scala.html Note: was broken in version 2.0.2 and fixed in 2.4.2
All these methods are necessary to join two streams into one stream. For example, you can create a Source out of a Source and a Flow, or you can create a Sink out of a Flow and a Sink, or you can create a Flow out of two Flows. For this, there are two basic … Read more
Your question is very general, so I’ll give a general answer from my point of view. First, I’ve got two usage scenario: cases where I’m reading data from kafka, processing it and writing some output back to kafka, for these I’m using kafka streams exclusively. cases where either the data source or sink is not … Read more
There are three ways this can be achieved: 1. Post Materialization with SourceQueue You can use Source.queue that materializes the Flow into a SourceQueue: case class Weather(zipCode : String, temperature : Double, raining : Boolean) val bufferSize = 100 //if the buffer fills up then this strategy drops the oldest elements //upon the arrival of … Read more
This answer is based on akka-stream version 2.4.2. The API can be slightly different in other versions. The dependency can be consumed by sbt: libraryDependencies += “com.typesafe.akka” %% “akka-stream” % “2.4.2” Alright, lets get started. The API of Akka Streams consists of three main types. In contrast to Reactive Streams, these types are a lot … Read more