diff options
| author | adamdottv <[email protected]> | 2025-05-12 14:32:27 -0500 |
|---|---|---|
| committer | adamdottv <[email protected]> | 2025-05-12 14:32:27 -0500 |
| commit | 36e5ae804e4bf0c96a0ce6cca90029e88c2da9b3 (patch) | |
| tree | e4dd3910956376104c2b3996c245393bf625bc32 /internal/pubsub | |
| parent | c9b90dd184084a2a3669db49717eb485c8861ee4 (diff) | |
| download | opencode-36e5ae804e4bf0c96a0ce6cca90029e88c2da9b3.tar.gz opencode-36e5ae804e4bf0c96a0ce6cca90029e88c2da9b3.zip | |
chore: rename coder -> primary
Diffstat (limited to 'internal/pubsub')
| -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 1a82011fc..b4caa98f3 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("created", "test message") + broker.Publish(EventTypeCreated, "test message") // Verify message is received select { case event := <-ch: - assert.Equal(t, "created", event.Type) + assert.Equal(t, EventTypeCreated, 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("created", i) + broker.Publish(EventTypeCreated, i) } // Wait for all subscribers to finish |