ferroui-dynamic-data 0.3.0

A port of DynamicData for FerroUI: reactive collections, change sets, observable caches and lists with their operators, independent of the user interface
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! `BufferInitial` (`Cache/ObservableCacheEx.BufferInitial.cs`).

macro_rules! buffer_initial_methods {
    () => {
        /// The change sets of the first `initial_buffer` after the first one, as one change set,
        /// then the change sets as they come (`BufferInitial(TimeSpan, IScheduler? = null)`, on the
        /// default scheduler).
        fn buffer_initial(&self, initial_buffer: std::time::Duration) -> std::rc::Rc<dyn ferroui_system::IObservable<crate::cache::ChangeSet<T, K>>> {
            self.buffer_initial_on(initial_buffer, ferroui_reactive::concurrency::SchedulerDefaults::time_based_operations())
        }

        /// [`buffer_initial`](Self::buffer_initial) on `scheduler` (`BufferInitial(TimeSpan,
        /// IScheduler)`).
        fn buffer_initial_on(
            &self,
            initial_buffer: std::time::Duration,
            scheduler: std::rc::Rc<dyn ferroui_reactive::concurrency::IScheduler>,
        ) -> std::rc::Rc<dyn ferroui_system::IObservable<crate::cache::ChangeSet<T, K>>> {
            let deferred = crate::cache::internal::defer_until_loaded(self.change_sets());
            ferroui_reactive::ObservableExt::publish_with(&deferred, move |shared: std::rc::Rc<dyn ferroui_system::IObservable<crate::cache::ChangeSet<T, K>>>| {
                let initial = ferroui_reactive::ObservableExt::take(
                    &crate::cache::flatten_buffer_result(ferroui_reactive::ObservableExt::buffer_time_on(&shared, initial_buffer, scheduler.clone())),
                    1,
                );
                ferroui_reactive::ObservableExt::concat(&initial, shared)
            })
        }
    };
}
pub(crate) use buffer_initial_methods;