RealtimeSubscription constructor

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

Initializes a RealtimeSubscription

Implementation

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