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