diff --git a/s2/append.go b/s2/append.go index b3a3db9..d92bce8 100644 --- a/s2/append.go +++ b/s2/append.go @@ -40,7 +40,7 @@ func (s *StreamClient) Append(ctx context.Context, input *AppendInput) (*AppendA pbInput := convertAppendInputToProto(prepared) httpClient := &httpClient{ - client: s.getHTTPClient(), + client: s.basinClient.httpClient, baseURL: s.basinClient.baseURL, accessToken: s.basinClient.accessToken, logger: s.logger, diff --git a/s2/read.go b/s2/read.go index 3c26814..022016b 100644 --- a/s2/read.go +++ b/s2/read.go @@ -97,7 +97,7 @@ func (s *StreamClient) Read(ctx context.Context, opts *ReadOptions) (*ReadBatch, batch, err := withRetries(ctx, s.basinClient.retryConfig, s.logger, func() (*ReadBatch, error) { httpClient := &httpClient{ - client: s.getHTTPClient(), + client: s.basinClient.httpClient, baseURL: s.basinClient.baseURL, accessToken: s.basinClient.accessToken, logger: s.logger,