Future<String> subscribe() async { throw UnimplementedError('subscribe() has not been implemented.'); }