Method close

internal/pluginhost/stream_bridge.go:78–93

(id string, errorMessage string)

}

func (b *streamBridge) close(id string, errorMessage string) {
	if b == nil || id == "" {
		return
	}
	b.mu.Lock()
	chunks := b.streams[id]
	delete(b.streams, id)
	b.mu.Unlock()
	if chunks == nil {
		return
	}
	if errorMessage != "" {
		chunks <- pluginapi.ExecutorStreamChunk{Err: fmt.Errorf("%s", errorMessage)}
	}
	close(chunks)
}