2019-11-24 12:27:50 +01:00
# Event Bus
A module to provide eventing capabilities using pub/sub.
## API
1. `new()` - create a new `EventBus`
### Structs:
**EventBus:**
2020-01-22 17:41:08 +01:00
1. `publish(name string, sender voidptr, args voidptr)` - publish an event with provided Params & name
2019-11-24 12:27:50 +01:00
2. `clear_all()` - clear all subscribers
2020-01-22 17:41:08 +01:00
3. `has_subscriber(name string)` - check if a subscriber to an event exists
2019-11-24 12:27:50 +01:00
**Subscriber:**
2020-01-22 17:41:08 +01:00
1. `subscribe(name string, handler EventHandlerFn)` - subscribe to an event
2. `subscribe_once(name string, handler EventHandlerFn)` - subscribe only once to an event
2020-07-28 18:08:16 +02:00
3. `subscribe_method(name string, handler EventHandlerFn, receiver voidptr)` - subscribe to an event and also set the `receiver` as a parameter. Since it's not yet possible to send methods as parameters, this is a workaround.
2020-01-22 17:41:08 +01:00
4. `is_subscribed(name string)` - check if we are subscribed to an event
5. `unsubscribe(name string)` - unsubscribe from an event
2019-11-24 12:27:50 +01:00
**Event Handler Signature:**
2020-01-22 17:41:08 +01:00
The function given to `subscribe` , `subscribe_method` and `subscribe_once` must match this:
2019-11-24 12:27:50 +01:00
```v
2020-07-28 18:08:16 +02:00
fn(receiver voidptr, args voidptr, sender voidptr){
2019-11-24 12:27:50 +01:00
}
2020-01-22 17:41:08 +01:00
// Since V can map structs to voidptr, this also works
struct ClickEvent {
x int
y int
}
// Example case where publisher sends ClickEvent as args.
2020-07-28 18:08:16 +02:00
fn onPress(receiver voidptr, e & ClickEvent, sender voidptr){
2020-01-22 17:41:08 +01:00
println(e.x)
2019-11-24 12:27:50 +01:00
//your code here...
}
```
## Usage
For **usage across modules** [check the example ](https://github.com/vlang/v/tree/master/examples/eventbus ).
2019-12-18 06:16:33 +01:00
_Note: As a general rule, you will need to **subscribe before publishing** ._
2019-11-24 12:27:50 +01:00
**main.v**
```v
module main
import eventbus
// initialize it globally
const (
eb = eventbus.new()
)
fn main(){
// get a mutable reference to the subscriber
mut sub := eb.subscriber
// subscribe to the 'error' event
sub.subscribe("error", on_error)
// start the work
do_work()
}
// the event handler
2020-07-28 18:08:16 +02:00
fn on_error(receiver voidptr, e & Error, work & Work) {
2020-01-22 17:41:08 +01:00
println('error occured on ${work.hours}. Error: ${e.message}')
2019-11-24 12:27:50 +01:00
}
```
**work.v**
```v
module main
2019-12-18 06:16:33 +01:00
struct Work{
hours int
}
2020-01-22 17:41:08 +01:00
struct Error {
message string
}
2019-11-24 12:27:50 +01:00
fn do_work(){
2019-12-18 06:16:33 +01:00
work := Work{20}
2019-11-24 12:27:50 +01:00
// get a mutable Params instance & put some data into it
2020-01-22 17:41:08 +01:00
error := & Error{"Error: no internet connection."}
2019-11-24 12:27:50 +01:00
// publish the event
2020-01-22 17:41:08 +01:00
eb.publish("error", work, error)
2019-11-24 12:27:50 +01:00
}
```
### Notes:
1. Each `EventBus` instance has it's own registry (i.e. there is no global event registry so you can't just subscribe to an event wherever you are.
2. Each `EventBus` has a `Subscriber` instance which will need to be either exposed or you can make small public helper functions specific to your module like (`onPress`, `onError` ) and etc.
3. The `eventbus` module has some helpers to ease getting/setting of Params (since V doesn't support empty interfaces yet or reflection) so use them (see usage above).
2019-12-18 06:16:33 +01:00
**The rationale behind separating Subscriber & Publisher:**
2019-11-24 12:27:50 +01:00
2020-07-28 18:08:16 +02:00
This is mainly for security because if publisher & subscriber are both passed around,
a client can easily publish events acting as the server.
So a client should only be able to use the Subscriber methods.