Replacing deprecated OnSubscribeFunc in unit test with OnSubscribe.