fixes name

This commit is contained in:
Deven Joshi
2021-11-10 20:01:02 +05:30
parent 9f9f0f510d
commit be8b319691
3 changed files with 18 additions and 20 deletions
@@ -227,13 +227,13 @@ class StreamChannelState extends State<StreamChannel> {
preferOffline: preferOffline,
);
Future<List<ChannelState>> _queryAtMessage({
Future<ChannelState?> _queryAtMessage({
String? messageId,
int before = 20,
int after = 20,
bool preferOffline = false,
}) async {
if (channel.state == null) return [];
if (channel.state == null) return null;
channel.state!.isUpToDate = false;
channel.state!.truncate();
@@ -245,17 +245,15 @@ class StreamChannelState extends State<StreamChannel> {
preferOffline: preferOffline,
);
channel.state!.isUpToDate = true;
return [];
return null;
}
return Future.wait([
queryAroundMessage(
messageId,
before: before,
after: after,
preferOffline: preferOffline,
),
]);
return queryAroundMessage(
messageId,
before: before,
after: after,
preferOffline: preferOffline,
);
}
///
@@ -267,7 +265,7 @@ class StreamChannelState extends State<StreamChannel> {
}) =>
channel.query(
messagesPagination: PaginationParams(
aroundId: messageId,
idAround: messageId,
before: before,
after: after,
),