subscribe<A, Ob, T, Or> method

@experimental Future<Subscription> subscribe<A, Ob, T, Or>(void callback(RealtimeMessage<A, Ob, T, Or>? message))

Subscribes to any changes in the feed, return a Subscription

Implementation

@experimental
Future<Subscription> subscribe<A, Ob, T, Or>(
  void Function(RealtimeMessage<A, Ob, T, Or>? message) callback,
) {
  checkNotNull(
    subscriber,
    'A subscriber must me provided in order to start listening to a feed',
  );
  final token = userToken ??
      TokenHelper.buildFeedToken(secret!, TokenAction.read, feedId);

  return subscriber!(token, feedId, (data) {
    final realtimeMessage = RealtimeMessage<A, Ob, T, Or>.fromJson(
      data!,
    );
    callback(realtimeMessage);
  });
}