Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
Publisher fan-outs stream events to conversation-scoped subscribers.
func (*Publisher) Publish ¶
func (p *Publisher) Publish(_ context.Context, ev *modelcallctx.StreamEvent) error
Publish implements modelcallctx.StreamPublisher.
func (*Publisher) Subscribe ¶
func (p *Publisher) Subscribe(convID string) (<-chan *modelcallctx.StreamEvent, func())
Subscribe returns a channel that receives events for the conversation.
Source Files
Click to show internal directories.
Click to hide internal directories.