retryAttachmentUpload should not be null

This commit is contained in:
Neevash Ramdial
2021-04-16 09:34:50 -04:00
parent e1ab168d33
commit 8a92392914
@@ -197,7 +197,7 @@ class Channel {
String messageId, String messageId,
Iterable<String> attachmentIds, Iterable<String> attachmentIds,
) { ) {
final message = state!.messages!.firstWhereOrNull( final message = state!.messages.firstWhereOrNull(
(it) => it.id == messageId, (it) => it.id == messageId,
); );
@@ -304,7 +304,7 @@ class Channel {
.remove(message.id) .remove(message.id)
?.completeError('Message Cancelled'); ?.completeError('Message Cancelled');
final quotedMessage = state?.messages?.firstWhereOrNull( final quotedMessage = state?.messages.firstWhereOrNull(
(m) => m.id == message.quotedMessageId, (m) => m.id == message.quotedMessageId,
); );
// ignore: parameter_assignments // ignore: parameter_assignments
@@ -771,11 +771,11 @@ class Channel {
if (res.message != null) { if (res.message != null) {
state!.addMessage(res.message!); state!.addMessage(res.message!);
} else { } else {
final oldIndex = state!.messages?.indexWhere((m) => m.id == messageId); final oldIndex = state!.messages.indexWhere((m) => m.id == messageId);
Message? oldMessage; Message? oldMessage;
if (oldIndex != null && oldIndex != -1) { if (oldIndex != -1) {
oldMessage = state!.messages![oldIndex]; oldMessage = state!.messages[oldIndex];
state!.updateChannelState(state!._channelState!.copyWith( state!.updateChannelState(state!._channelState!.copyWith(
messages: state?.messages?..remove(oldMessage), messages: state?.messages?..remove(oldMessage),
)); ));
@@ -784,7 +784,7 @@ class Channel {
.expand((messages) => messages) .expand((messages) => messages)
.firstWhereOrNull((m) => m.id == messageId); .firstWhereOrNull((m) => m.id == messageId);
if (oldMessage?.parentId != null) { if (oldMessage?.parentId != null) {
final parentMessage = state!.messages!.firstWhereOrNull( final parentMessage = state!.messages.firstWhereOrNull(
(element) => element.id == oldMessage!.parentId, (element) => element.id == oldMessage!.parentId,
); );
if (parentMessage != null) { if (parentMessage != null) {
@@ -1372,7 +1372,7 @@ class ChannelClientState {
/// Retry failed message /// Retry failed message
Future<void> retryFailedMessages() async { Future<void> retryFailedMessages() async {
final failedMessages = final failedMessages =
<Message>[...messages!, ...threads!.values.expand((v) => v)] <Message>[...messages, ...threads!.values.expand((v) => v)]
.where( .where(
(message) => (message) =>
message.status != MessageSendingStatus.sent && message.status != MessageSendingStatus.sent &&
@@ -1528,7 +1528,7 @@ class ChannelClientState {
} }
/// Channel message list /// Channel message list
List<Message>? get messages => _channelState!.messages; List<Message> get messages => _channelState!.messages;
/// Channel message list as a stream /// Channel message list as a stream
Stream<List<Message>?> get messagesStream => Stream<List<Message>?> get messagesStream =>