'This should be called by the consumer when the producer is
unregistered.
Stop streaming data to the consumer.'

def stopStreaming(self):

    if self._finished:
        return
    self._finished = True
    self._coopTask.stop()
