reactive-streams

Вопрос или проблема У меня есть мультикастовый приёмник с стратегией directBestEffort, в который я помещаю различные события. Я хотел бы создать поток, который буферизует N количество событий, и в случае переполнения сразу закрывается с ошибкой, например