WW-Digital / reactive-kinesis / 247

90%

push

travis-ci

Add an Akka Stream Sink graph stage for Kinesis.  (#47)

Add a `KinesisSinkGraphStage` that uses an underlying `KinesisProducerActor` to do the heavy lifting. The stream manages back pressure by allowing only a fixed number of outstanding messages. A materialized value is used to indicate when a stream has been finished (or failed).

44 of 44 new or added lines in 2 files covered. (100.0%)

395 of 438 relevant lines covered (90.18%)

1.79 hits per line