subscribe method

Future<RealtimeSubscription> subscribe()

Subscribe to real-time events with type safety

Example

final subscription = await realtime.observe<Message>('chat.room1')
  .on(RealtimeObserverEvent.data, (event) => print('Message: ${event.data}'))
  .subscribe();

Implementation

Future<RealtimeSubscription> subscribe() async {
  return _realtime._subscribe(
    RealtimeSubscriptionOptions<T>(
      topic: _topic,
      fields: _fields,
      filter: _filter,
      onData: _dataHandler,
      onError: _errorHandler,
    ),
  );
}