(t *testing.T, s *server.Server, opts ...nats.Option)
| 1833 | } |
| 1834 | |
| 1835 | func jsClient(t *testing.T, s *server.Server, opts ...nats.Option) (*nats.Conn, jetstream.JetStream) { |
| 1836 | t.Helper() |
| 1837 | nc := client(t, s, opts...) |
| 1838 | js, err := jetstream.New(nc) |
| 1839 | if err != nil { |
| 1840 | t.Fatalf("Unexpected error getting JetStream context: %v", err) |
| 1841 | } |
| 1842 | return nc, js |
| 1843 | } |
| 1844 | |
| 1845 | func expectOk(t *testing.T, err error) { |
| 1846 | t.Helper() |
no test coverage detected