subscribe<A, Ob, T, Or> method
- @experimental
- void callback(
- RealtimeMessage<
A, Ob, T, Or> ? message
- RealtimeMessage<
inherited
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);
});
}