neuecc
6389c12152
remove TestSDK
2025-02-17 19:54:37 +09:00
neuecc
2020bb63ea
unit test move to xUnit.v3
2025-02-15 06:29:26 +09:00
neuecc
230d7f26ee
Amb -> Race
2025-02-15 06:13:33 +09:00
neuecc
ce68c67e4f
Fix TimeoutFrame behavior #298
2025-02-13 20:25:36 +09:00
neuecc
2b53194535
Fix Switch Operator dispose order, close #300
2025-02-13 20:11:52 +09:00
neuecc
cd1365e2ca
Merge remote-tracking branch 'origin/main'
2025-02-13 19:45:09 +09:00
neuecc
b98303692e
CombineLatest(empty) returns OnCompleted() immediately, close #290
2025-02-13 19:45:03 +09:00
Yoshifumi Kawai
65f2d10541
Merge pull request #305 from TORISOUP/fix_throttlefirstlast
...
Fix: ThrottleFirstLast stops working
2025-02-13 19:23:00 +09:00
neuecc
3e6fcbead5
Add Observable.ChunkUntil
2025-02-13 17:19:11 +09:00
neuecc
acb1abf091
test library change from fluentassertions to shuldly
2025-02-13 16:04:45 +09:00
TORISOUP
645095e2d9
Fix: ThrottleFirstLastAsyncSampler stops working
2025-02-09 20:43:05 +09:00
neuecc
198a489760
Merge branch 'main' of https://github.com/Cysharp/R3
2024-08-13 16:55:41 +09:00
neuecc
b607ef09fa
a
2024-08-13 16:55:38 +09:00
Yoshifumi Kawai
cd2d5e88eb
Merge pull request #243 from erri120/where-not-null
...
Add `WhereNotNull` operator
2024-08-13 16:48:52 +09:00
neuecc
ed773af7c5
Fix TakeLast causes runtime exception #242
2024-08-13 16:44:21 +09:00
erri120
3f16e316b0
Add WhereNotNull operator
...
Using optimized `WhereSelect`, the `WhereNotNull` operator is very
common and many libraries and applications had to DIY implement
this for `System.IObservable<T>`.
2024-08-10 19:19:50 +02:00
neuecc
f055c0ae66
ZipLatest raise OnCompleted when can not produce values anymore
2024-07-26 17:11:04 +09:00
neuecc
c11a7ba85c
CombineLatest raise OnCompleted when can not produce values anymore
2024-07-26 16:40:53 +09:00
neuecc
578e81c2de
Zip raise OnCompleted when can not produce values anymore
2024-07-26 16:20:17 +09:00
neuecc
ad6fb9cbb8
Add Observable.TakeUntil(predicate) #238
2024-07-25 20:13:11 +09:00
neuecc
6dffe983f8
new Subject
2024-07-25 18:20:16 +09:00
neuecc
a34866de8c
Fix ChunkFrame behavior
2024-07-25 12:13:18 +09:00
claudiaw797
ae2f760e89
Fix MinByAsync and MaxByAsync, add tests
2024-07-20 20:39:21 +02:00
neuecc
710b7be856
Fix Observable.Concat stall when element complete immediately #232
2024-07-17 14:38:08 +09:00
neuecc
e1c65bb1f0
Add SubscribeOnSynchronize
2024-07-12 14:26:16 +09:00
TORISOUP
be9ae6d47d
Fixed Trampoline could not be reused
2024-05-28 18:11:41 +09:00
neuecc
6659cb686d
Add TakeUntil(async), SkipUntil(async)
2024-03-02 17:36:19 +09:00
neuecc
4f59ae1b7d
Add Append/Prepend(IEnumerable<T>), (Func<T>), (TState, Func<TState, T>)
2024-03-01 23:46:00 +09:00
neuecc
dc203dade2
Add Chunk(count, skip)
2024-02-29 15:24:13 +09:00
neuecc
4a90bb4f57
Change Chunk(TimeSpan) timer start when first value comes
2024-02-29 15:01:27 +09:00
neuecc
c6cdd83535
Fix debounce, throttlefirstlast, throttlelast async overload does not handle correctly when func return immediately
2024-02-29 14:45:18 +09:00
neuecc
6850c4ca2e
WIP async chunk
2024-02-29 02:42:43 +09:00
neuecc
6d0604f37d
AwaitOperation.Latest -> AwaitOperation.ThrottleFirstLast
2024-02-21 18:22:57 +09:00
neuecc
3e9a3c04ff
ThrottleLast -> ThrottleFirstLast
2024-02-21 18:06:49 +09:00
Yoshifumi Kawai
de90f78afe
Merge pull request #126 from Cysharp/await2
...
bool cancelOnCompleted option to SelectAwait/WhereAwait/SubscribeAwait
2024-02-21 18:04:11 +09:00
Yoshifumi Kawai
55956a6ea9
Merge pull request #123 from Cysharp/timestamp-operator
...
Add FrameCount, FrameInterval, TimeInterval, Timestamp
2024-02-21 18:03:44 +09:00
neuecc
0d5f1a70a6
bool cancelOnCompleted option to SelectAwait/WhereAwait/SubscribeAwait
2024-02-21 18:03:04 +09:00
neuecc
a45deb327d
Add FrameCount, FrameInterval, TimeInterval, Timestamp
2024-02-21 12:21:59 +09:00
neuecc
9433b4d3b4
Add ThrottleLatest
2024-02-20 17:10:24 +09:00
Michael Stonis
1e52f0177d
Adds support to only get the latest value when using Async operators
...
This is helpful when a flood of requests come in and you just want the most recent one after the one you last processed.
This implementation is based off of `AwaitOperation.Sequential`, but uses a bounded channel with capacity for a singular item that will replace the oldest value
2024-02-17 10:33:36 -06:00
hadashiA
8f304c9e5f
Add tests
2024-02-16 12:49:23 +09:00
neuecc
b110cd3ef1
Add Index
2024-02-15 05:50:16 +09:00
neuecc
ecdf9d425f
Add Observable.Trampoline
2024-02-09 15:31:51 +09:00
neuecc
c43c39b9c5
Improve Notification struct size(breaking changes, Notification.Result? -> Notification.Result)
2024-02-09 15:31:31 +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
db86f6a736
AwaitOpearation done
2024-01-29 17:29:47 +09:00
neuecc
811f8ccdc4
Merge branch 'main' into awaitoperation-switch
2024-01-29 15:43:55 +09:00
Yoshifumi Kawai
bdc0489c9b
Merge pull request #65 from Cysharp/hadashiA/add-aggregate-overload
...
Add more overloads of AggregateAsync
2024-01-28 10:38:52 +09:00
neuecc