Streams API Puppet Module