File tree Expand file tree Collapse file tree 1 file changed +13
-0
lines changed
UI/ChatSignalR/UnoChat.Client/UnoChat.Shared Expand file tree Collapse file tree 1 file changed +13
-0
lines changed Original file line number Diff line number Diff line change @@ -209,6 +209,7 @@ private IDisposable ShouldSendThemeToThemeObserver(IObserver<string> themeObserv
209
209
210
210
private IDisposable ShouldSendModelsAddedToAllMessagesToMessageObserver ( IObserver < Model > messageObserver )
211
211
{
212
+ #if ! __WASM__
212
213
return Observable
213
214
. FromEvent < NotifyCollectionChangedEventHandler , NotifyCollectionChangedEventArgs > (
214
215
handler => ( s , e ) => handler ( e ) ,
@@ -220,6 +221,18 @@ private IDisposable ShouldSendModelsAddedToAllMessagesToMessageObserver(IObserve
220
221
. Delay ( TimeSpan . FromMilliseconds ( 10 ) , Schedulers . Default ) // Wait for the list view to have been updated
221
222
. ObserveOn ( Schedulers . Dispatcher )
222
223
. Subscribe ( messageObserver ) ;
224
+ #else
225
+ return Observable
226
+ . FromEvent < NotifyCollectionChangedEventHandler , NotifyCollectionChangedEventArgs > (
227
+ handler => ( s , e ) => handler ( e ) ,
228
+ handler => _allMessages . CollectionChanged += handler ,
229
+ handler => _allMessages . CollectionChanged -= handler )
230
+ . Where ( args => args . Action == NotifyCollectionChangedAction . Add )
231
+ . Select ( args => args . NewItems . OfType < Message . Model > ( ) . FirstOrDefault ( ) )
232
+ . Where ( model => model != null )
233
+ . ObserveOn ( Schedulers . Dispatcher )
234
+ . Subscribe ( messageObserver ) ;
235
+ #endif
223
236
}
224
237
225
238
public IDisposable Activate ( IObservable < object > messageToSendBoxReturn , IObserver < string > themeObserver , IObserver < Message . Model > messageObserver )
You can’t perform that action at this time.
0 commit comments