werbenhu / eventbus / 22802453022

98%

push

github

refactor(eventbus): improve channel and pipe management logic

- Replace atomic counter with simple increment for CowMap length calculation
- Change channel stopCh type from chan any to chan struct{} for proper signaling
- Store reflect.Value of topic in channel struct to avoid repeated conversions
- Simplify transfer method by removing redundant topic parameter
- Use LoadOrStore to prevent concurrent channel creation and properly close duplicates
- Modify Pipe handlers map to use handler pointer as key via reflect.ValueOf().Pointer()
- Replace sending struct{} on stopCh with channel close for graceful shutdown
- Correct PublishSync to call synchronous publish method in singleton wrapper

28 of 34 new or added lines in 4 files covered. (82.35%)

272 of 278 relevant lines covered (97.84%)

2219.91 hits per line