()
| 23 | } |
| 24 | |
| 25 | func newModelStreamBridge() *modelStreamBridge { |
| 26 | return &modelStreamBridge{streams: make(map[string]modelStreamEntry)} |
| 27 | } |
| 28 | |
| 29 | func (b *modelStreamBridge) open(ownerCallbackID string, chunks <-chan handlers.ModelExecutionChunk, cancel context.CancelFunc) string { |
| 30 | if b == nil || chunks == nil { |