@override int stopStreaming() { final status = _consumeStatus(); if (status == 0) _streaming = false; return status; }