(t *testing.T, db database.Store)
| 2773 | } |
| 2774 | |
| 2775 | func newSubscribeTestServer(t *testing.T, db database.Store) *Server { |
| 2776 | t.Helper() |
| 2777 | |
| 2778 | return &Server{ |
| 2779 | db: db, |
| 2780 | logger: slogtest.Make(t, &slogtest.Options{IgnoreErrors: true}), |
| 2781 | pubsub: dbpubsub.NewInMemory(), |
| 2782 | } |
| 2783 | } |
| 2784 | |
| 2785 | func newBufferedSubscribeTestServer(t *testing.T, db database.Store, chatID uuid.UUID) *Server { |
| 2786 | t.Helper() |
no test coverage detected