getThreads method
Stream<Feed>
getThreads({
- String? tag,
- ThreadsSortOrder sort = ThreadsSortOrder.created,
- bool requestLatest = false,
Implementation
Stream<Feed> getThreads({
String? tag,
ThreadsSortOrder sort = ThreadsSortOrder.created,
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();
}