libp2p/go-eventbus
1
0
Fork 0
mirror of https://github.com/libp2p/go-eventbus.git synced 2024-12-26 23:30:08 +08:00
Code Issues Projects Releases Wiki Activity
54 Commits 15 Branches 7 Tags 211 KiB
fix/16
Commit Graph

54 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Steven Allen
25d54bbbec fix: serialize publishing 
Ensure that all subscribers see events in the same order. This also ensures that
the subscribers never see the initial "latest" event after some other event.

fixes #16
 2019-06-27 22:34:44 +02:00
Łukasz Magiera
04058af20a
Merge pull request #18 from libp2p/fix/fully-drain 
fix: completely drain on close
 2019-06-27 22:15:01 +02:00
Steven Allen
a77f09c820 fix: completely drain on close 
Issue: We could partially drain and end up with, e.g., a close event missing a
matching open event.
 2019-06-27 20:17:04 +02:00
Steven Allen
df5be7d7dd
Merge pull request #11 from libp2p/fix/things 
Fix close deadlock and Sub type error
 2019-06-27 20:13:09 +02:00
Łukasz Magiera
0c299185af
Merge pull request #14 from libp2p/nit/simple-reflect 
nit: avoid ValueOf
 2019-06-27 19:40:02 +02:00
Steven Allen
12782426ed nit: avoid ValueOf 
We only need TypeOf.
 2019-06-27 19:20:43 +02:00
Łukasz Magiera
9c3fe0580a
Merge pull request #13 from libp2p/feat/buffer-by-default 
Enable buffering by default
 2019-06-25 22:07:48 +02:00
Jakub Sztandera
0976d4b358 Enable buffering by default 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
 2019-06-25 20:47:02 +02:00
Łukasz Magiera
61257f90a2
Merge pull request #12 from libp2p/feat/better-bench 
Improve benchmarks
 2019-06-22 17:41:26 +02:00
Jakub Sztandera
85cd6aa7c7 Add benchmarks for subscribe and emitter 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
 2019-06-22 17:39:16 +02:00
Jakub Sztandera
fc8fa53d99 Clean up format 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
 2019-06-22 15:50:30 +02:00
Jakub Sztandera
facb8f2fed Reduce number of samples 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
 2019-06-22 15:48:06 +02:00
Jakub Sztandera
454cbe5497 Make the test fail in reasonable time 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
 2019-06-22 15:45:09 +02:00
Jakub Sztandera
d2cb2a10b6 Improve benchmarks 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
 2019-06-22 15:30:12 +02:00
Łukasz Magiera
3fd76c7eac Add test for #10 2019-06-22 15:14:04 +02:00
Łukasz Magiera
525a0e67fe fix close deadlock and Sub type error 2019-06-22 12:05:03 +02:00
Łukasz Magiera
6212a929bf refactor interfaces (#9) 2019-06-21 17:50:36 +01:00
Raúl Kripalani
f100eac4ef
Refinements before first release 🎉 (#7) 2019-06-20 16:17:57 +01:00
Raúl Kripalani
c7aefba960 update go-libp2p-core dep. 2019-06-20 00:01:35 +01:00
Raúl Kripalani
fe6d9d1489
rename eventbus package. (#4) 2019-06-19 16:55:25 +01:00
Łukasz Magiera
131418619d
Merge pull request #1 from libp2p/feat/implement 
Implement
 2019-06-19 17:32:27 +02:00
Raúl Kripalani
015ba825e9 fix compile error in tests. 2019-06-19 16:21:55 +01:00
Raúl Kripalani
8b7b645962 remove superfluous types. 2019-06-19 16:13:28 +01:00
Raúl Kripalani
bd8289f870 make Emitter an interface. 2019-06-19 16:10:03 +01:00
Łukasz Magiera
1ab671b0ca
Merge pull request #2 from libp2p/ci/enable 
ci: enable
 2019-06-19 16:04:46 +02:00
Łukasz Magiera
a1807fd415 Drop the interface 2019-06-19 15:36:31 +02:00
Łukasz Magiera
2341c42dab
Merge pull request #3 from libp2p/feat/interface 
generify options.
 2019-06-19 15:13:27 +02:00
Raúl Kripalani
2ea3b26fbd generify options. 2019-06-19 14:09:12 +01:00
Łukasz Magiera
04b7ec33de BasicBus to basicBus 2019-06-19 15:00:22 +02:00
Łukasz Magiera
401bb25f47 return struct from NewBus 2019-06-19 14:48:41 +02:00
Łukasz Magiera
2f028f9607 Update Emitter docs 2019-06-19 14:32:55 +02:00
Łukasz Magiera
942c134291 Move close to EmitFunc 2019-06-19 14:27:37 +02:00
Łukasz Magiera
d23aaa9b5c Address @stebalien's review 2019-06-19 14:22:10 +02:00
Łukasz Magiera
1cb839f3b0 Document options 2019-06-19 14:13:48 +02:00
Steven Allen
3abafaf475 ci: enable 2019-06-19 14:12:41 +02:00
Łukasz Magiera
71ffb0ebf1 Use reflect.Type in node map 2019-06-19 13:51:25 +02:00
Łukasz Magiera
8b50ba1149 Some more docs 2019-06-19 12:46:59 +02:00
Łukasz Magiera
c54e8ebbe9 Simplify withNode a bit 2019-06-19 12:31:36 +02:00
Łukasz Magiera
5b845983c2 Fix data races 2019-06-19 12:13:18 +02:00
Łukasz Magiera
287e2189af Stateful emits 2019-06-16 21:42:47 +02:00
Jakub Sztandera
821aef1f4b Use slice instead of map 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
 2019-06-16 19:20:10 +02:00
Łukasz Magiera
1c855d2c2d Gofmt 2019-06-16 19:20:10 +02:00
Łukasz Magiera
7961d7f4a3 ForceSubType 2019-06-16 18:15:35 +02:00
Łukasz Magiera
7954da5541 Merge branch 'feat/sendto' into feat/implement 2019-06-16 17:25:24 +02:00
Łukasz Magiera
a783093124 Set correct B.N on BenchmarkMs1e0m6 2019-06-16 17:25:13 +02:00
Łukasz Magiera
1e0dd64ef6 Subscribe with user provided typed channels 2019-06-16 17:20:33 +02:00
Łukasz Magiera
001f18ea77 POC SendTo 2019-06-14 18:57:21 +02:00
Łukasz Magiera
604d51ce75 Basic README 2019-06-13 22:38:12 +02:00
Łukasz Magiera
ec3723a818 Address @bigs review 2019-06-13 22:25:53 +02:00
Łukasz Magiera
246814bc1e Placeholder for options in the interface 2019-06-13 10:04:12 +02:00