(meta *wshrpc.StreamMeta, writer StreamWriter)
| 77 | } |
| 78 | |
| 79 | func (b *Broker) AttachStreamWriter(meta *wshrpc.StreamMeta, writer StreamWriter) error { |
| 80 | b.lock.Lock() |
| 81 | defer b.lock.Unlock() |
| 82 | |
| 83 | if _, exists := b.writers[meta.Id]; exists { |
| 84 | return fmt.Errorf("writer already registered for stream id %s", meta.Id) |
| 85 | } |
| 86 | |
| 87 | b.writers[meta.Id] = writer |
| 88 | b.readerRoutes[meta.Id] = meta.ReaderRouteId |
| 89 | b.writerRoutes[meta.Id] = meta.WriterRouteId |
| 90 | |
| 91 | return nil |
| 92 | } |
| 93 | |
| 94 | func (b *Broker) DetachStreamWriter(streamId string) { |
| 95 | b.lock.Lock() |
no outgoing calls
no test coverage detected