Какой предмет только выбрасывает предметы после подписки

Question

В rxJava я хочу, чтобы субъект начинал испускать «новые» элементы только после вызова метода подписки.Ближе всего к этому я обнаружил PublishSubject, но в документах указано следующее:

PublishSubject отправляет наблюдателю только те элементы, которые отправляются исходными наблюдаемыми объектами после времени подписки.

Обратите внимание, что PublishSubject может начать испускать элементы сразу после создания (если вы не предприняли шаги, чтобы предотвратить это), и поэтому существует риск того, что один или несколько элементов могут быть потеряны между временем создания субъекта инаблюдатель подписывается на него.

Не совсем ясно, что имеется в виду под «если вы не предприняли шаги, чтобы предотвратить это».Или есть лучший тип предмета, который я могу использовать?

Answer 1

Вы можете использовать оператор publish :

он не начинает излучать элементы, когда на него подписаны, а только когда к нему применяется оператор Connect.Таким образом, вы можете предложить Observable начать испускание предметов в любое время по вашему выбору.