libraries/gubgub
1
0
Fork 0
Code Pull Requests Actions Activity

reworded docs and changed delivery bench cases

Browse Source
This commit is contained in:
Natercio Moniz
2024-08-22 17:22:18 +01:00
parent f4321c6261
commit 5863882fe3
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
bench_data_test.go
View File

@@ -60,24 +60,24 @@ var deliveryCases = []benchSubscriberSetup{
Subscriber: NoOp[int](), Subscriber: NoOp[int](),
}, },
{ {
Name: "10K Subscribers 1% unsubscribe", Name: "10K Subscribers 10% unsubscribe",
Count: 10000, Count: 10000,
Subscriber: Quiter(100), Subscriber: Quiter(10),
}, },
{ {
Name: "100K Subscribers 1% unsubscribe", Name: "100K Subscribers 10% unsubscribe",
Count: 100000, Count: 100000,
Subscriber: Quiter(100), Subscriber: Quiter(10),
}, },
{ {
Name: "10K Subscribers 2% unsubscribe", Name: "10K Subscribers 50% unsubscribe",
Count: 10000, Count: 10000,
Subscriber: Quiter(50), Subscriber: Quiter(2),
}, },
{ {
Name: "100K Subscribers 2% unsubscribe", Name: "100K Subscribers 50% unsubscribe",
Count: 100000, Count: 100000,
Subscriber: Quiter(50), Subscriber: Quiter(2),
}, },
} }

4
wrappers.go
View File

@@ -1,6 +1,6 @@
package gubgub package gubgub
// Forever wrapper makes it more explicit that a subscriber will never stop consuming messages. // Forever wraps a subscriber that will never stop consuming messages.
// This helps avoiding subscribers that always return TRUE. // This helps avoiding subscribers that always return TRUE.
func Forever[T any](fn func(T)) Subscriber[T] { func Forever[T any](fn func(T)) Subscriber[T] {
return func(msg T) bool { return func(msg T) bool {
@@ -9,7 +9,7 @@ func Forever[T any](fn func(T)) Subscriber[T] {
} }
} }
// Once returns a subscriber that will consume only one message. // Once wraps a subscriber that will consume only one message.
// This helps avoiding subscribers that always return FALSE. // This helps avoiding subscribers that always return FALSE.
func Once[T any](fn func(T)) Subscriber[T] { func Once[T any](fn func(T)) Subscriber[T] {
return func(t T) bool { return func(t T) bool {