94 Commits
Author SHA1 Message Date
neuecc 578e81c2de Zip raise OnCompleted when can not produce values anymore 2024-07-26 16:20:17 +09:00
neuecc f2d81ab95b Zip, ZipLatest, CombineLatest from ObservableExtensions to Observable 2024-07-25 19:30:49 +09:00
neuecc d772f0039c default bool cancelOnCompleted to false 2024-07-25 19:18:56 +09:00
neuecc 6dffe983f8 new Subject 2024-07-25 18:20:16 +09:00
neuecc db5f3f4ae0 change readme 2024-07-17 15:19:29 +09:00
neuecc 710b7be856 Fix Observable.Concat stall when element complete immediately #232 2024-07-17 14:38:08 +09:00
neuecc 8f07e98c40 Fix Observable.Defer throws exception when continuous operator using Subscribe internally 2024-06-25 20:42:59 +09:00
neuecc 8482849834 Fix SerialDisposable, it affects for Observable<Observable>>.Switch, Enumerable<Observable>.Concat 2024-03-18 19:57:18 +09:00
neuecc 1b807ade3c Add ReactiveProperty.HasObservers 2024-03-11 15:27:02 +09:00
neuecc ad2c93ee1c fix RP node iteration 2024-03-11 13:00:43 +09:00
neuecc 0f125f47b5 fix ReactiveProperty more 2024-03-10 10:08:07 +09:00
neuecc e42faaf3bc Fix ReactiveProperty broken observer iterate when multiple subscribe and dispose any 2024-03-10 00:07:14 +09:00
neuecc 8e05affb92 Add ObservePropertyChanged, ObservePropertyChanging 2024-03-01 12:51:26 +09:00
neuecc 98407204d8 done 2024-02-29 14:15:00 +09:00
neuecc 6850c4ca2e WIP async chunk 2024-02-29 02:42:43 +09:00
neuecc 266518a30a RM 2024-02-16 17:45:36 +09:00
neuecc 1c89fd2f77 default async/await configureAwait to true 2024-02-14 19:27:16 +09:00
neuecc 07ae120a01 ReactiveProperty.OnValueChanging/Changed, GetValueRef 2024-02-03 15:46:45 +09:00
neuecc b79b07f9b3 Add Select/Where/SubscribeAwait(int maxConcurrent) overload 2024-01-31 20:34:32 +09:00
neuecc a1d7d7d62d Add Debounce throttleDurationSelector overload 2024-01-31 19:13:30 +09:00
neuecc 419ec19a5d Add ThrttleFirst/Last accepts Task/Observable sampler
change ThrottleLast sampling timing
2024-01-31 18:28:50 +09:00
neuecc 1820775204 ReactiveProperty JsonSerializable 2024-01-30 21:02:14 +09:00
neuecc 5882020d7d Add CreateFrom 2024-01-29 15:32:50 +09:00
neuecc a8bb7f311e Auto stash before merge of "main" and "origin/main" 2024-01-29 15:20:39 +09:00
neuecc 8bfc29f4b6 Add SelectAwait, WhereAwait, SubscribeAwait 2024-01-22 19:23:38 +09:00
neuecc db05dcecf9 Merge branch 'main' into select-await 2024-01-22 15:52:50 +09:00
neuecc db1b4e75f1 b 2024-01-21 17:57:40 +09:00
neuecc 1d19fe6297 SubscriptionTracker -> OBservableTracker 2024-01-19 12:41:29 +09:00
neuecc fcfa4ae7f3 WIP impl SelectAwait 2024-01-15 18:07:12 +09:00
neuecc e89588eb86 DataAnnotation 2024-01-14 15:11:17 +09:00
neuecc 96875428a6 ReadMe complete 2024-01-09 05:29:15 +09:00
neuecc c0397fae46 reference done 2024-01-08 18:04:40 +09:00
neuecc f4a1d3c25e Operator Reference 2024-01-08 14:36:38 +09:00
neuecc 88bc5bd142 remove logger dependency 2024-01-07 01:06:44 +09:00
neuecc 57b0a77350 All, Any, IsEmpty, MaxBy, MinBy, SequenceEqual, ToDictionary, ToLookup 2024-01-05 01:55:22 +09:00
neuecc 41556c0a3f Scan, Distinct, DistinctUntilChanged, DefaultIfEmpty 2024-01-05 00:33:21 +09:00
neuecc 27c5d394b0 Switch(not tested) 2024-01-04 23:07:19 +09:00
neuecc ee29a96d12 CombineLatest, Zip, ZipLatest, WithLatestFrom(not tested) 2024-01-04 19:22:36 +09:00
neuecc 4a6e1c1fce Timeout, TimeoutFrame 2024-01-04 00:57:27 +09:00
neuecc 2a34f17aad Debounce, ThrottleFirst, Sample + Frame 2024-01-04 00:14:07 +09:00
neuecc 1f3ed41658 Chunk, ChunkFrame 2024-01-03 20:51:33 +09:00
neuecc 43143e98c5 Skip, SkipFrame 2024-01-02 01:42:34 +09:00
neuecc e199029660 ReplaySubject 2024-01-01 18:33:00 +09:00
neuecc bcd70e8ae8 redesigned thread-safe Subject 2023-12-30 00:32:16 +09:00
neuecc cf8b5e7fce implementing Multicast 2023-12-28 01:12:49 +09:00
neuecc f2f2e33efa IgnoreElements 2023-12-27 23:57:13 +09:00
neuecc ee7137046c AsUnitObservable, Cast, OfType 2023-12-27 23:40:25 +09:00
neuecc 8bbf48890f Merge 2023-12-27 23:08:33 +09:00
neuecc a6bbd5395e Amb 2023-12-27 17:43:54 +09:00
neuecc d106a82582 TODO:ObserveOn 2023-12-26 21:45:43 +09:00