A generic class that can provide a subscription resource
typedef SubscriptionCall = Future<Stream<QueryResult>> Function();