module Firehose::Client::Producer