fix messagelistview loading errors
This commit is contained in:
@@ -4,7 +4,6 @@ import 'dart:math';
|
|||||||
|
|
||||||
import 'package:dio/dio.dart';
|
import 'package:dio/dio.dart';
|
||||||
import 'package:logging/logging.dart';
|
import 'package:logging/logging.dart';
|
||||||
import 'package:pedantic/pedantic.dart' show unawaited;
|
|
||||||
import 'package:rxdart/rxdart.dart';
|
import 'package:rxdart/rxdart.dart';
|
||||||
import 'package:stream_chat/src/api/retry_queue.dart';
|
import 'package:stream_chat/src/api/retry_queue.dart';
|
||||||
import 'package:stream_chat/src/debounce.dart';
|
import 'package:stream_chat/src/debounce.dart';
|
||||||
@@ -336,10 +335,10 @@ class Channel {
|
|||||||
_messageAttachmentsUploadCompleter[message.id] =
|
_messageAttachmentsUploadCompleter[message.id] =
|
||||||
attachmentsUploadCompleter;
|
attachmentsUploadCompleter;
|
||||||
|
|
||||||
unawaited(_uploadAttachments(
|
_uploadAttachments(
|
||||||
message.id,
|
message.id,
|
||||||
message.attachments.map((it) => it.id),
|
message.attachments.map((it) => it.id),
|
||||||
));
|
);
|
||||||
|
|
||||||
// ignore: parameter_assignments
|
// ignore: parameter_assignments
|
||||||
message = await attachmentsUploadCompleter.future;
|
message = await attachmentsUploadCompleter.future;
|
||||||
@@ -386,10 +385,10 @@ class Channel {
|
|||||||
_messageAttachmentsUploadCompleter[message.id] =
|
_messageAttachmentsUploadCompleter[message.id] =
|
||||||
attachmentsUploadCompleter;
|
attachmentsUploadCompleter;
|
||||||
|
|
||||||
unawaited(_uploadAttachments(
|
_uploadAttachments(
|
||||||
message.id,
|
message.id,
|
||||||
message.attachments.map((it) => it.id),
|
message.attachments.map((it) => it.id),
|
||||||
));
|
);
|
||||||
|
|
||||||
// ignore: parameter_assignments
|
// ignore: parameter_assignments
|
||||||
message = await attachmentsUploadCompleter.future;
|
message = await attachmentsUploadCompleter.future;
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ import 'package:stream_chat/src/extensions/map_extension.dart';
|
|||||||
import 'package:dio/dio.dart';
|
import 'package:dio/dio.dart';
|
||||||
import 'package:logging/logging.dart';
|
import 'package:logging/logging.dart';
|
||||||
import 'package:meta/meta.dart';
|
import 'package:meta/meta.dart';
|
||||||
import 'package:pedantic/pedantic.dart' show unawaited;
|
|
||||||
import 'package:rxdart/rxdart.dart';
|
import 'package:rxdart/rxdart.dart';
|
||||||
import 'package:stream_chat/src/api/channel.dart';
|
import 'package:stream_chat/src/api/channel.dart';
|
||||||
import 'package:stream_chat/src/api/connection_status.dart';
|
import 'package:stream_chat/src/api/connection_status.dart';
|
||||||
@@ -510,7 +509,7 @@ class StreamChatClient {
|
|||||||
|
|
||||||
if (status == ConnectionStatus.connected &&
|
if (status == ConnectionStatus.connected &&
|
||||||
state.channels?.isNotEmpty == true) {
|
state.channels?.isNotEmpty == true) {
|
||||||
unawaited(queryChannelsOnline(filter: {
|
queryChannelsOnline(filter: {
|
||||||
'cid': {
|
'cid': {
|
||||||
'\$in': state.channels.keys.toList(),
|
'\$in': state.channels.keys.toList(),
|
||||||
},
|
},
|
||||||
@@ -522,7 +521,7 @@ class StreamChatClient {
|
|||||||
online: true,
|
online: true,
|
||||||
));
|
));
|
||||||
},
|
},
|
||||||
));
|
);
|
||||||
} else {
|
} else {
|
||||||
_synced = false;
|
_synced = false;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -22,8 +22,6 @@ dependencies:
|
|||||||
uuid: ^2.2.2
|
uuid: ^2.2.2
|
||||||
web_socket_channel: ^1.1.0
|
web_socket_channel: ^1.1.0
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
dev_dependencies:
|
dev_dependencies:
|
||||||
build_runner: ^1.10.0
|
build_runner: ^1.10.0
|
||||||
freezed: ^0.12.7
|
freezed: ^0.12.7
|
||||||
|
|||||||
@@ -129,7 +129,7 @@ class _MessageListCoreState extends State<MessageListCore> {
|
|||||||
|
|
||||||
bool defaultFilter(Message m) {
|
bool defaultFilter(Message m) {
|
||||||
final isMyMessage = m.user.id == _currentUser.id;
|
final isMyMessage = m.user.id == _currentUser.id;
|
||||||
final isDeletedOrShadowed = m.isDeleted || m.shadowed;
|
final isDeletedOrShadowed = m.isDeleted == true || m.shadowed == true;
|
||||||
if (isDeletedOrShadowed && !isMyMessage) return false;
|
if (isDeletedOrShadowed && !isMyMessage) return false;
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -10,7 +10,11 @@ environment:
|
|||||||
flutter: ">=1.17.0"
|
flutter: ">=1.17.0"
|
||||||
|
|
||||||
dependencies:
|
dependencies:
|
||||||
stream_chat: ^1.3.2-beta
|
stream_chat:
|
||||||
|
git:
|
||||||
|
url: https://github.com/GetStream/stream-chat-flutter.git
|
||||||
|
ref: develop
|
||||||
|
path: packages/stream_chat
|
||||||
flutter:
|
flutter:
|
||||||
sdk: flutter
|
sdk: flutter
|
||||||
rxdart: ^0.25.0
|
rxdart: ^0.25.0
|
||||||
|
|||||||
Reference in New Issue
Block a user