docs: add example

Author: neurosnap

README.md

@@ -2,6 +2,43 @@
 
 A generic pubsub implementation for Go.
 
+```go
+package main
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"log/slog"
+
+	"github.com/google/uuid"
+	"github.com/picosh/pubsub"
+)
+
+func main() {
+	ctx := context.TODO()
+	logger := slog.Default()
+	broker := pubsub.NewMulticast(logger)
+
+	chann := []*pubsub.Channel{
+		pubsub.NewChannel("my-topic"),
+	}
+
+	go func() {
+		writer := bytes.NewBufferString("my data")
+		pubID := uuid.NewString()
+		broker.Pub(ctx, pubID, writer, chann, false)
+	}()
+
+	reader := bytes.NewBufferString("")
+	subID := uuid.NewString()
+	broker.Sub(ctx, subID, reader, chann, false)
+
+	// result
+	fmt.Println("data from pub:", reader)
+}
+```
+
 ## pubsub over ssh
 
 The simplest pubsub system for everyday automation needs.

cmd/basic/main.go

@@ -0,0 +1,34 @@
+package main
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"log/slog"
+
+	"github.com/google/uuid"
+	"github.com/picosh/pubsub"
+)
+
+func main() {
+	ctx := context.TODO()
+	logger := slog.Default()
+	broker := pubsub.NewMulticast(logger)
+
+	chann := []*pubsub.Channel{
+		pubsub.NewChannel("my-topic"),
+	}
+
+	go func() {
+		writer := bytes.NewBufferString("my data")
+		pubID := uuid.NewString()
+		_ = broker.Pub(ctx, pubID, writer, chann, false)
+	}()
+
+	reader := bytes.NewBufferString("")
+	subID := uuid.NewString()
+	_ = broker.Sub(ctx, subID, reader, chann, false)
+
+	// result
+	fmt.Println("data from pub:", reader)
+}