222
90%

Ran 21 Dec 2017 05:26PM UTC

Jobs 2

Files 14

Run time 5s

Badge

Embed ▾

pending completion

Build # 222

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

351 of 397 relevant lines covered (88.41%)

1.76 hits per line

Jobs

ID	Job ID	Ran	Files	Coverage
1	222.1	21 Dec 2017 05:26PM UTC	0	88.16	Travis Job 222.1
2	222.2	21 Dec 2017 05:26PM UTC	0	88.1	Travis Job 222.2

Source Files on build 222

Detailed source file information is not available for this build.

WW-Digital / reactive-kinesis / 222
90%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Jobs

Source Files on build 222

WW-Digital / reactive-kinesis / 222 90%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Jobs

Source Files on build 222

WW-Digital / reactive-kinesis / 222
90%

README BADGES
x