RealtimeSubscription constructor

RealtimeSubscription({
  1. required Future<void> close(),
  2. required Future<void> unsubscribe(),
  3. required Future<void> update({
    1. List<Object>? channels,
    2. List<String>? queries,
    }),
  4. required List<String> channels,
  5. required List<String> queries,
  6. required StreamController<RealtimeMessage> controller,
})

Initializes a RealtimeSubscription

Implementation

RealtimeSubscription({
  required this.close,
  required this.unsubscribe,
  required this.update,
  required this.channels,
  required this.queries,
  required this.controller,
}) : stream = controller.stream;