Samuel Berthe
|
a133373ee3
|
rename lo.Batch to lo.Buffer and lo.BatchWithTImeout to lo.BufferWithTimeout
|
2022-11-15 18:24:44 +01:00 |
|
Samuel Berthe
|
34ef81e140
|
feat: rename ChannelMerge to FanIn and add FanOut (#262)
|
2022-11-12 00:30:53 +01:00 |
|
Anandraj Elumalai
|
27d881052b
|
fix: resolved code smells (#258)
Made the project to smell good
Co-authored-by: aelumalai <aelumalai@paypal.com>
|
2022-10-31 15:48:04 +01:00 |
|
VictorAssunc
|
640e00c286
|
chore: test coverage improvement (#240)
* chore: improves channel functions test coverage
* chore: improves errors functions test coverage
* chore: improves map functions test coverage
* chore: improves parallel slice functions test coverage
* chore: improves slice functions test coverage
* fix: uses atomic counter on parallel/slice_test
* Update channel_test.go
Co-authored-by: Samuel Berthe <dev@samuel-berthe.fr>
|
2022-10-22 19:05:07 +02:00 |
|
H
|
d899a1ce0b
|
feat: add ChannelMerge (#241)
Co-authored-by: hhu <hhu@tencent.com>
|
2022-10-14 10:31:28 +02:00 |
|
Samuel Berthe
|
f44773e344
|
feat: adding CountValuesBy
|
2022-10-10 21:26:19 +02:00 |
|
Samuel Berthe
|
5d99d5a0ca
|
adding ChannelToSlice
|
2022-10-07 00:53:43 +02:00 |
|
Samuel Berthe
|
0bd7b562a9
|
New helper collection: channel (#95)
* feat(channels): add ToChannel + Generator + Batch + BatchWithTimeout (WIP)
* feat: return duration of Batch**** helpers
* doc: improve BatchWithTimeout doc
* fix(BatchWithTimeout): replace time.After by time.NewTimer in order to prevent memory leak
* doc: improve BatchWithTimeout doc
|
2022-10-07 00:36:31 +02:00 |
|
Samuel Berthe
|
31f3bc3a85
|
test: parallel tests everywhere (#228)
|
2022-10-02 21:38:26 +02:00 |
|
Samuel Berthe
|
0fb185c15c
|
feat: adding lo.ChannelDispatcher and 6 basic dispatching strategies
|
2022-09-05 13:01:10 +02:00 |
|