reactive-streams Publisher and Subscriber implementation for Amazon Kinesis