opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: replace ConsumeInbound with InboundChan select in client test

Browse source 
MessageBus does not expose a ConsumeInbound method. Use a select on
InboundChan() with context cancellation, matching the pattern used in
the bus package tests.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Amir Mamaghani 2026-03-20 13:21:33 +01:00
parent 7733c05095
commit 9be27c75a2
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
pkg/channels/pico/client_test.go
View file

@ -189,13 +189,14 @@ func TestClientChannel_ReceivesServerMessage(t *testing.T) {
// The echoed message.create is processed by handleServerMessage which // The echoed message.create is processed by handleServerMessage which
// calls HandleMessage → PublishInbound. Consume it from the bus. // calls HandleMessage → PublishInbound. Consume it from the bus.
msg, ok := mb.ConsumeInbound(ctx) select {
if !ok { case msg := <-mb.InboundChan():
t.Fatal("timed out waiting for echoed message")
}
if msg.Content != "ping" { if msg.Content != "ping" {
t.Fatalf("received = %q, want %q", msg.Content, "ping") t.Fatalf("received = %q, want %q", msg.Content, "ping")
} }
case <-ctx.Done():
t.Fatal("timed out waiting for echoed message")
}
} }
func TestClientChannel_StartTyping(t *testing.T) { func TestClientChannel_StartTyping(t *testing.T) {