title: SignalR Core and streaming from server using RX Subject
body: <p>I've been search high and low, but there's just too little information out there covering this particular topic. </p>
  
  <p>This is part of my server side SignalR Hub:</p>
  
  <pre><code>public class MyHub : Hub
  { 
    private ReplaySubject&lt;string&gt; _stream = new ReplaySubject&lt;string&gt;();
  
    public IObservable&lt;string&gt; Stream()
    {
       return _stream.AsObservable();
    }
  
    public void TriggerTest()
    {
       return _stream.OnNext("message");
    }
  }
  </code></pre>
  
  <p>I successfully connect to the hub and are able to invoke the TriggerTest() method on the server. </p>
  
  <p>The following code on the client, however, is never triggered when _stream receives a new message on the server:</p>
  
  <pre><code>this.socket.stream('Stream').subscribe({
          next: (value) =&gt; {
              console.log('stream response:');
              console.log(value);
          },
          error: (err) =&gt; {
              console.warn(err);
          },
          complete: () =&gt; {
              console.log('stream completed');
          }
      });
  </code></pre>
  
  <p>I assume the problem lies on the server, more precisely on the Observable / Subject part, but couldn't find any guidance out there. Any help appreciated! Thanks!</p>