(id string)
| 78 | } |
| 79 | |
| 80 | func (b *modelStreamBridge) close(id string) { |
| 81 | if b == nil || id == "" { |
| 82 | return |
| 83 | } |
| 84 | b.mu.Lock() |
| 85 | entry := b.streams[id] |
| 86 | delete(b.streams, id) |
| 87 | b.mu.Unlock() |
| 88 | if entry.cancel != nil { |
| 89 | entry.cancel() |
| 90 | } |
| 91 | } |