diff options
| author | adamdottv <[email protected]> | 2025-05-12 11:22:19 -0500 |
|---|---|---|
| committer | adamdottv <[email protected]> | 2025-05-12 11:22:19 -0500 |
| commit | d20d0c5a95e19250a7d83b4eb30f9d7b460104da (patch) | |
| tree | a0ce46f8aabd6ade3936145e81a94291f51a30f3 /internal | |
| parent | 5af3c05d41f80615716f085d6d8eda859bf54ad4 (diff) | |
| download | opencode-d20d0c5a95e19250a7d83b4eb30f9d7b460104da.tar.gz opencode-d20d0c5a95e19250a7d83b4eb30f9d7b460104da.zip | |
chore: cleanup
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/pubsub/broker_test.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/internal/pubsub/broker_test.go b/internal/pubsub/broker_test.go index 581a513a3..1a82011fc 100644 --- a/internal/pubsub/broker_test.go +++ b/internal/pubsub/broker_test.go @@ -51,12 +51,12 @@ func TestBrokerPublish(t *testing.T) { ch := broker.Subscribe(ctx) // Publish a message - broker.Publish(CreatedEvent, "test message") + broker.Publish("created", "test message") // Verify message is received select { case event := <-ch: - assert.Equal(t, CreatedEvent, event.Type) + assert.Equal(t, "created", event.Type) assert.Equal(t, "test message", event.Payload) case <-time.After(100 * time.Millisecond): t.Fatal("timeout waiting for message") @@ -122,7 +122,7 @@ func TestBrokerConcurrency(t *testing.T) { // Publish messages to all subscribers for i := range numSubscribers { - broker.Publish(CreatedEvent, i) + broker.Publish("created", i) } // Wait for all subscribers to finish |