Представьте, что у вас есть наблюдаемое воспроизведение, созданное с помощью одного из Replay перегружает. Существует ли вариант Replay, который создает наблюдаемое воспроизведение с помощью метода, позволяющего удалить элемент/сообщение/элемент из буфера воспроизведения?
Мне нужен наблюдаемый повтор, чтобы избежать состояния гонки: два наблюдаемых объекта A и B создают связанные сообщения. Если A создает сообщение m, то B может последовать его примеру с соответствующим сообщением m' (но это необязательно).
Чтобы отфильтровать m' из всех сообщений B, подписчик на A регистрирует подписчика с B (отфильтровано для точного сообщения m'), поскольку только при получении m программа сможет предсказать, как будет выглядеть потенциально входящее m'.
Однако иногда m' поступает даже до того, как был запланирован запуск подписчика на A, что означает, что подписчик на m' еще не зарегистрирован. Я могу решить эту проблему, обернув B в качестве наблюдаемого воспроизведения, но я хочу иметь возможность очищать обработанные сообщения из буфера воспроизведения, потому что я знаю, что каждое из сообщений B будет обрабатываться ровно одним подписчиком.
