Commit 1ea0d46b authored by Wojciech Tyczynski's avatar Wojciech Tyczynski

Set headers in Watch() and Stream() requests

parent ac5d2cec
...@@ -648,6 +648,7 @@ func (r *Request) Watch() (watch.Interface, error) { ...@@ -648,6 +648,7 @@ func (r *Request) Watch() (watch.Interface, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
req.Header = r.headers
client := r.client client := r.client
if client == nil { if client == nil {
client = http.DefaultClient client = http.DefaultClient
...@@ -715,6 +716,7 @@ func (r *Request) Stream() (io.ReadCloser, error) { ...@@ -715,6 +716,7 @@ func (r *Request) Stream() (io.ReadCloser, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
req.Header = r.headers
client := r.client client := r.client
if client == nil { if client == nil {
client = http.DefaultClient client = http.DefaultClient
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment