NATS Context Option

nats-ctx.go

func ExampleContext() {
	nc, err := nats.Connect("localhost")
	if err != nil {
		log.Fatal(err)
	}

	// Base context
	ctx := nats.Context(context.Background())

	js, err := nc.JetStream()
	if err != nil {
		log.Fatal(err)
	}

	// New context from base context.
	ctx2, cancel := context.WithCancel(ctx)
	defer cancel()

	js.AddStream(&nats.StreamConfig{Name: "foo"}, nats.Context(ctx2))

	ctx3, cancel := context.WithTimeout(ctx2, 2*time.Second)
	defer cancel()

	js.Publish("foo", []byte("Hello JS!"), nats.Context(ctx3))

	// Output:
}