Use MyStreamConsumer callbacks wherever possible