jlzapata/rxjs-signalr

RxJS wrapper for ASP.NET SignalR

When consuming SignalR based services I wanted to be able to treat receiving data as an observable stream. This library provides a thin wrapper to allow consumption of SignalR services using RxJS Observables.

What is RxJS?

Refer to the RxJS docs for that.

What is SignalR?

Refer to the ASP.NET SignalR docs.

Getting started

rxjs and Signalr

This package relies on signalr and rxjs packages.

Install

Install using npm:

npm install observable-signalr --save

Creating a hub

Create using factory method:

import { createSignalRHub } from 'observable-signalr';

const hub = createSignalRHub('{hubName}');

Create using constructor:

import { SignalRHub } from 'observable-signalr';

const hub = new SignalRHub('{hubName}');

Receiving data from SignalR

import { createSignalRHub } from 'observable-signalr';

const hub = createSignalRHub('{hubName}');
hub.on('{name of event/method}').subscribe(data => {
    // Perform logic here
});
hub.start();

Sending data to SignalR

import { createSignalRHub } from 'observable-signalr';

const hub = createSignalRHub('{hubName}');
hub.start();
hub.send('{name of event/method}', {});