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

chore(bus):update function comments

Browse source
This commit is contained in:
ItsT0ng 2026-02-27 20:57:25 +11:00
parent f63a609601
commit 3ae0ec2100
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
pkg/bus/bus.go
View file

@ -30,6 +30,8 @@ func (mb *MessageBus) PublishInbound(msg InboundMessage) {
mb.inbound <- msg mb.inbound <- msg
} }
// ConsumeInbound returns the next inbound message and whether the read succeeded.
// The bool is false when the context is cancelled or the channel is closed.
func (mb *MessageBus) ConsumeInbound(ctx context.Context) (InboundMessage, bool) { func (mb *MessageBus) ConsumeInbound(ctx context.Context) (InboundMessage, bool) {
select { select {
case msg, ok := <-mb.inbound: case msg, ok := <-mb.inbound:
@ -48,6 +50,8 @@ func (mb *MessageBus) PublishOutbound(msg OutboundMessage) {
mb.outbound <- msg mb.outbound <- msg
} }
// SubscribeOutbound returns the next outbound message and whether the read succeeded.
// The bool is false when the context is cancelled or the channel is closed.
func (mb *MessageBus) SubscribeOutbound(ctx context.Context) (OutboundMessage, bool) { func (mb *MessageBus) SubscribeOutbound(ctx context.Context) (OutboundMessage, bool) {
select { select {
case msg, ok := <-mb.outbound: case msg, ok := <-mb.outbound: