()
| 28 | } |
| 29 | |
| 30 | func newStreamBridge() *streamBridge { |
| 31 | return &streamBridge{streams: make(map[string]chan pluginapi.ExecutorStreamChunk)} |
| 32 | } |
| 33 | |
| 34 | func (b *streamBridge) open(ctx context.Context) (string, <-chan pluginapi.ExecutorStreamChunk, func()) { |
| 35 | if b == nil { |