Class RetainLatestStreamNotifications<T>

All Implemented Interfaces:
AccumulationFacility<T,T>, AccumulationFacility.HomotypicAccumulation<T>, AccumulationFacility.RetainLatest<T>, NotificationAccumulator<Consumer<? super T>,T,T>

final class RetainLatestStreamNotifications<T> extends AbstractReducingStreamNotifications<T> implements AccumulationFacility.RetainLatest<T>
  • Constructor Details

    • RetainLatestStreamNotifications

      RetainLatestStreamNotifications()