Implement ObservableHubProxy without Rx packages