diff --git a/lib/core/providers/app_providers.dart b/lib/core/providers/app_providers.dart
index d068a8c..955994c 100644
--- a/lib/core/providers/app_providers.dart
+++ b/lib/core/providers/app_providers.dart
@@ -267,7 +267,7 @@ class SocketConnectionStream extends _$SocketConnectionStream {
   ProviderSubscription<AsyncValue<SocketService?>>? _serviceSubscription;
   VoidCallback? _cancelConnectListener;
   VoidCallback? _cancelDisconnectListener;
-  SocketConnectionState _latestState = SocketConnectionState.disconnected;
+  SocketConnectionState _latestState = SocketConnectionState.connecting;
 
   @override
   Stream<SocketConnectionState> build() {
@@ -320,7 +320,7 @@ class SocketConnectionStream extends _$SocketConnectionStream {
   void _handleServiceChange(SocketService? service) {
     if (service == null) {
       _unbindSocket();
-      _emit(SocketConnectionState.disconnected);
+      _emit(SocketConnectionState.connecting);
       return;
     }
 
@@ -462,8 +462,24 @@ class ConversationDeltaStream extends _$ConversationDeltaStream {
     _socketSubscription?.dispose();
     _socketSubscription = null;
   }
+
+  /// Provides direct access to the underlying stream.
+  /// Exposed as a method to avoid property-based lint violations.
+  Stream<ConversationDelta> stream() =>
+      _controller?.stream ?? const Stream<ConversationDelta>.empty();
 }
 
+final conversationDeltaEventsProvider =
+    StreamProvider.family<ConversationDelta, ConversationDeltaRequest>((
+      ref,
+      request,
+    ) {
+      final notifier = ref.watch(
+        conversationDeltaStreamProvider(request).notifier,
+      );
+      return notifier.stream();
+    });
+
 // Attachment upload queue provider
 final attachmentUploadQueueProvider = Provider<AttachmentUploadQueue?>((ref) {
   final api = ref.watch(apiServiceProvider);
diff --git a/lib/core/services/connectivity_service.dart b/lib/core/services/connectivity_service.dart
index d9ce86b..fbaf834 100644
--- a/lib/core/services/connectivity_service.dart
+++ b/lib/core/services/connectivity_service.dart
@@ -246,7 +246,7 @@ final isOnlineProvider = Provider<bool>((ref) {
   if (reviewerMode) return true;
   final status = ref.watch(connectivityStatusProvider);
   return status.when(
-    data: (status) => status == ConnectivityStatus.online,
+    data: (status) => status != ConnectivityStatus.offline,
     loading: () => true, // Assume online while checking
     error: (_, _) =>
         true, // Assume online on error to avoid false offline states