Start continuous data streaming
Future<Map<String, dynamic>> startDataStreaming() { throw UnimplementedError('startDataStreaming() has not been implemented.'); }