Создание наблюдаемого Rx.NET в концентраторе SignalR

У меня есть концентратор SignalR, который прослушивает запросы клиентов и использует Rx.NET для наблюдения за таблицей базы данных, чтобы отправлять обновления запрашивающему их клиенту, как только они становятся доступными. Но похоже, что экземпляр Observer, созданный в хабе по запросу клиента, уничтожается (GC?) сразу после завершения вызова метода; поэтому я не получаю обновлений.

Это моя текущая реализация Hub:

public class BookHub : Hub {
    private readonly BookService _service = new BookService();

    public void RequestBookUpdate(string author) {
        BookObserver observer = new BookObserver(Context.connectionId);
        IDisposable unsubscriber = _service.RequestBookUpdate(author, observer);
    }
}

BookService возвращает запрос LINQ, преобразованный в Observable:

public IDisposable RequestBookUpdate(string author, BookObserver observer) {
    var query = from b in db.Book where b.Author.Contains(author) select b;
    IObservable<Book> observable = query.ToObservable();
    IDisposable unsubscriber = observable.Subscribe(observer);
    return unsubscriber;
}

BookObserver просто отправляет новые извлеченные элементы конкретному клиенту, запросившему обновления (идентифицированному connectionId):

// omissis

private static readonly IHubContext _context = GlobalHost.ConnectionManager.GetHubContext<BookHub>();
private readonly string _connectionId;

public BookObserver(string connectionId) {
    connectionId = _connectionId:
}

public void OnNext(Book value) {
    _context.Clients.Client(_connectionId).foundNewBook(value);
}

Меня не волнует уничтожение экземпляра BookService, но я хочу, чтобы экземпляр BookObserver оставался в живых, поэтому я могу вызывать unsubscriber.Dispose() только тогда, когда клиент отключается. Это возможно?