fix stream channel query
This commit is contained in:
@@ -163,7 +163,7 @@ class StreamChannelState extends State<StreamChannel> {
|
|||||||
channel.state == null) return;
|
channel.state == null) return;
|
||||||
_queryTopMessagesController.add(true);
|
_queryTopMessagesController.add(true);
|
||||||
|
|
||||||
late Message message;
|
Message? message;
|
||||||
if (channel.state!.threads.containsKey(parentId)) {
|
if (channel.state!.threads.containsKey(parentId)) {
|
||||||
final thread = channel.state!.threads[parentId]!;
|
final thread = channel.state!.threads[parentId]!;
|
||||||
if (thread.isNotEmpty) {
|
if (thread.isNotEmpty) {
|
||||||
@@ -175,7 +175,7 @@ class StreamChannelState extends State<StreamChannel> {
|
|||||||
final response = await channel.getReplies(
|
final response = await channel.getReplies(
|
||||||
parentId,
|
parentId,
|
||||||
PaginationParams(
|
PaginationParams(
|
||||||
lessThan: message.id,
|
lessThan: message?.id,
|
||||||
limit: limit,
|
limit: limit,
|
||||||
),
|
),
|
||||||
preferOffline: preferOffline,
|
preferOffline: preferOffline,
|
||||||
|
|||||||
Reference in New Issue
Block a user