Dan Ryan

I have a requirement to be able to support streaming from both Kinesis and DynamoDB streams. Would it be possible to either a) refactor the code to support the injection...

Use polling to avoid unnecessary waiting time on the test. Running locally, the tests now take 10 seconds, down from 30 seconds.