A library to handle realtime SignalR (.NET Core) events using redux, rxjs and redux-observable.
Inspired by https://github.com/Odonno/ngrx-signalr-core
npm install redux rxjs redux-obsevable @aspnet/signalr --save
npm install redux-observable-signalr-core --save
import { signalR$ } from " redux-observable-signalr-core " ;
const epics = combineEpics (
... signalR$
) ;
First, you will start the application by dispatching the creation of one Hub.
import { createSignalRHub } from " redux-observable-signalr-core/lib/actions " ;
const hub = {
hubName : ' hub name ' ,
url : ' https://localhost/path '
} ;
store . dispatch ( createSignalRHub ( hub ) ) ;
Then you will create an Epic to start listening to events before starting the Hub.
import { signalrHubUnstarted , startSignalRHub } from " redux-observable-signalr-core/lib/actions " ;
import { mergeMapHubToAction } from " redux-observable-signalr-core/lib/operators " ;
const listenNotification$ : Epic < Action , Action , IRootState > = action$ =>
action$ . pipe (
filter ( isActionOf ( signalrHubUnstarted ) ) ,
mergeMapHubToAction ( ( { hub } ) => {
const receiveNotification$ = hub
. on < Notification > ( method )
. pipe (
map ( actions . notificationReceived )
) ;
const exististingNotifications$ = hub
. on < Notification [ ] > ( existing )
. pipe (
map ( actions . getNotificationsSuccess )
) ;
return merge ( receiveNotification$ , exististingNotifications$ , of ( startSignalRHub ( NotificationHub ) ) ) ;
} )
) ;
You can also send events at anytime.
import { findHub } from " redux-observable-signalr-core/lib/signalRHub " ;
import { hubNotFound } from " redux-observable-signalr-core/lib/actions " ;
const sendNotification$ : Epic < Action , Action , IRootState > = action$ =>
action$ . pipe (
filter ( isActionOf ( actions . sendNotification ) ) ,
mergeMap ( action => {
const hub = findHub ( NotificationHub ) ;
if ( ! hub ) {
return of ( hubNotFound ( NotificationHub ) ) ;
}
return hub
. send ( sendNotification , action . payload )
. pipe (
map ( actions . sendNotificationSuccess ) ,
catchError ( ( e ) => of ( actions . sendNotificationError ) )
) ;
} )
) ;
Since .NET Core, client needs to handle the SignalR Hub reconnection by itself. redux-observable-signalr-core does it for you automatically, no additional setup required.
