getThreads method

Stream<Feed> getThreads({
  1. String? tag,
  2. ThreadsSortOrder? sort,
  3. bool requestLatest = false,
})

Implementation

Stream<Feed> getThreads({
  String? tag,
  ThreadsSortOrder? sort,
  bool requestLatest = false,
}) {
  final key = _getThreadsKey(tag, sort?.name);
  final BehaviorSubject<Feed> controller;
  if (_feedStreamControllers.containsKey(key)) {
    controller = _feedStreamControllers[key]!;
  } else {
    controller = BehaviorSubject<Feed>();
    _feedStreamControllers[key] = controller;

    unawaited(
      _fetchAndAddFeed(
        tag: tag,
        sort: sort?.toFeedSortOrder(),
        requestLatest: requestLatest,
        isThreads: true,
      ),
    );
  }

  return controller.asBroadcastStream();
}