Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val roomsTemperatureReadings =
- Stream.continually(TemperatureReading(randomRoom, randomTemperature))
- Source(roomsTemperatureReadings)
- .alsoTo(Sink.foreach(reading => createRoomIfNotExist(reading.roomId)))
- .to(Sink.foreach(saveReading))
- .run()
Add Comment
Please, Sign In to add comment
