minor updates

packages/stream_chat/lib/src/client/retry_queue.dart

@@ -118,6 +118,7 @@ class RetryQueue {
       } catch (e) {
         if (e is! StreamChatNetworkError || !e.isRetriable) {
           _messageQueue.removeMessage(message);
+          _sendFailedEvent(message);
           return true;
         }
         // retry logic

packages/stream_chat/lib/stream_chat.dart

@@ -7,6 +7,7 @@ export 'package:dio/src/options.dart';
 export 'package:dio/src/options.dart' show ProgressCallback;
 export 'package:logging/logging.dart' show Logger, Level;
 export 'package:rate_limiter/rate_limiter.dart';
+export 'package:uuid/uuid.dart';
 
 export './src/core/api/attachment_file_uploader.dart'
     show AttachmentFileUploader;

packages/stream_chat_flutter/lib/src/message_input/message_input.dart

@@ -421,9 +421,7 @@ class MessageInputState extends State<MessageInput> {
   Widget build(BuildContext context) {
     Widget child = ValueListenableBuilder<Message>(
       valueListenable: messageInputController,
-      builder: (context, value, wid) {
-        print('VALUE ${value.text}');
-        return DecoratedBox(
+      builder: (context, value, wid) => DecoratedBox(
         decoration: BoxDecoration(
           color: _messageInputTheme.inputBackgroundColor,
         ),
@@ -485,8 +483,7 @@ class MessageInputState extends State<MessageInput> {
             ),
           ),
         ),
-        );
-      },
+      ),
     );
     if (_isEditing) {
       child = Material(

packages/stream_chat_flutter_core/lib/src/message_input_controller.dart

@@ -88,7 +88,7 @@ class MessageInputController extends ValueNotifier<Message> {
   ///
   String get text => _textEditingController.text;
 
-  final Message _initialMessage;
+  Message _initialMessage;
 
   ///
   set message(Message message) {
@@ -206,13 +206,20 @@ class MessageInputController extends ValueNotifier<Message> {
   }
 
   /// Set the [value] to the initial [Message] value.
-  void reset() => value = _initialMessage;
+  void reset({bool resetId = true}) {
+    if (resetId) {
+      _initialMessage = _initialMessage.copyWith(
+        id: const Uuid().v4(),
+      );
+    }
+    value = _initialMessage;
+  }
 
   @override
   void dispose() {
-    super.dispose();
     removeListener(_textEditingSyncer);
     _textEditingController.dispose();
+    super.dispose();
   }
 }