2
90%
master: 90%

Ran 21 Dec 2017 05:26PM UTC

Files 13

Run time 0s

Badge

Embed ▾

Committed 21 Dec 2017 05:19PM UTC coverage: 88.101% (+1.6%) from 86.538%

Job # 222.2

Build Type

push

travis-ci

Committed by

markglh

Commit Message

Fix #25 by providing an Akka Stream Source graph stage for Kinesis. (#39)

Adds an Akka Streams `Source` is that can be used with streams. It is possible to create a source from a ConsumerConf or directly from the consumer name that is defined in the configuration. Every message that is emitted to the stream is of type CommitableEvent[ConsumerEvent] and has to be committed explicitly downstream with a call to event.commit(). It is possible to map to a different type of CommittableEvent via the map and mapAsync functionality.

A KinesisConsumer is used internally for the Kinesis.source. All rules described here for the KinesisConsumer also apply for the stream source.

Run Details

348 of 395 relevant lines covered (88.1%)

0.88 hits per line

WW-Digital / reactive-kinesis / 222 / 2
90%
master: 90%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 222.2

WW-Digital / reactive-kinesis / 222 / 2 90% master: 90%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 222.2

WW-Digital / reactive-kinesis / 222 / 2
90%
master: 90%

README BADGES
x