Helpers
(t *testing.T, s *server.Server, opts ...nats.Option)
| 1195 | // Helpers |
| 1196 | |
| 1197 | func client(t *testing.T, s *server.Server, opts ...nats.Option) *nats.Conn { |
| 1198 | t.Helper() |
| 1199 | nc, err := nats.Connect(s.ClientURL(), opts...) |
| 1200 | if err != nil { |
| 1201 | t.Fatalf("Unexpected error: %v", err) |
| 1202 | } |
| 1203 | return nc |
| 1204 | } |
| 1205 | |
| 1206 | func jsClient(t *testing.T, s *server.Server, opts ...nats.Option) (*nats.Conn, nats.JetStreamContext) { |
| 1207 | t.Helper() |