-
Notifications
You must be signed in to change notification settings - Fork 0
/
example_test.go
55 lines (45 loc) · 1.05 KB
/
example_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package tt_test
import (
"context"
"log"
"github.com/gregoryv/mq"
"github.com/gregoryv/tt"
"github.com/gregoryv/tt/event"
)
// Example shows a simple client for connect, publish a QoS 0 and
// disconnect.
func Example_client() {
client := tt.NewClient()
client.SetServer("tcp://localhost:1883")
ctx := context.Background()
go client.Run(ctx)
// v is either an packet or a event type
for v := range client.Events() {
switch v := v.(type) {
case event.ClientUp:
_ = client.Send(ctx, mq.NewConnect())
case event.ClientConnect:
// do something once you are connected
p := mq.Pub(0, "gopher/happy", "yes")
_ = client.Send(ctx, p)
case *mq.Publish:
_ = v // do something the received packet
case event.ClientStop:
// do some clean up maybe
}
}
}
// Example shows how to run the provided server.
func Example_server() {
srv := tt.NewServer()
ctx := context.Background()
go srv.Run(ctx)
for v := range srv.Events() {
switch v := v.(type) {
case event.ServerStop:
if v.Err != nil {
log.Println(v.Err)
}
}
}
}