@@ -34,7 +34,7 @@ func TestCompletionsStreamWrongModel(t *testing.T) {
34
34
func TestCreateCompletionStream (t * testing.T ) {
35
35
client , server , teardown := setupOpenAITestServer ()
36
36
defer teardown ()
37
- server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , r * http.Request ) {
37
+ server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , _ * http.Request ) {
38
38
w .Header ().Set ("Content-Type" , "text/event-stream" )
39
39
40
40
// Send test responses
@@ -106,7 +106,7 @@ func TestCreateCompletionStream(t *testing.T) {
106
106
func TestCreateCompletionStreamError (t * testing.T ) {
107
107
client , server , teardown := setupOpenAITestServer ()
108
108
defer teardown ()
109
- server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , r * http.Request ) {
109
+ server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , _ * http.Request ) {
110
110
w .Header ().Set ("Content-Type" , "text/event-stream" )
111
111
112
112
// Send test responses
@@ -151,7 +151,7 @@ func TestCreateCompletionStreamError(t *testing.T) {
151
151
func TestCreateCompletionStreamRateLimitError (t * testing.T ) {
152
152
client , server , teardown := setupOpenAITestServer ()
153
153
defer teardown ()
154
- server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , r * http.Request ) {
154
+ server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , _ * http.Request ) {
155
155
w .Header ().Set ("Content-Type" , "application/json" )
156
156
w .WriteHeader (429 )
157
157
@@ -182,7 +182,7 @@ func TestCreateCompletionStreamRateLimitError(t *testing.T) {
182
182
func TestCreateCompletionStreamTooManyEmptyStreamMessagesError (t * testing.T ) {
183
183
client , server , teardown := setupOpenAITestServer ()
184
184
defer teardown ()
185
- server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , r * http.Request ) {
185
+ server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , _ * http.Request ) {
186
186
w .Header ().Set ("Content-Type" , "text/event-stream" )
187
187
188
188
// Send test responses
@@ -228,7 +228,7 @@ func TestCreateCompletionStreamTooManyEmptyStreamMessagesError(t *testing.T) {
228
228
func TestCreateCompletionStreamUnexpectedTerminatedError (t * testing.T ) {
229
229
client , server , teardown := setupOpenAITestServer ()
230
230
defer teardown ()
231
- server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , r * http.Request ) {
231
+ server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , _ * http.Request ) {
232
232
w .Header ().Set ("Content-Type" , "text/event-stream" )
233
233
234
234
// Send test responses
@@ -263,7 +263,7 @@ func TestCreateCompletionStreamUnexpectedTerminatedError(t *testing.T) {
263
263
func TestCreateCompletionStreamBrokenJSONError (t * testing.T ) {
264
264
client , server , teardown := setupOpenAITestServer ()
265
265
defer teardown ()
266
- server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , r * http.Request ) {
266
+ server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , _ * http.Request ) {
267
267
w .Header ().Set ("Content-Type" , "text/event-stream" )
268
268
269
269
// Send test responses
@@ -305,7 +305,7 @@ func TestCreateCompletionStreamBrokenJSONError(t *testing.T) {
305
305
func TestCreateCompletionStreamReturnTimeoutError (t * testing.T ) {
306
306
client , server , teardown := setupOpenAITestServer ()
307
307
defer teardown ()
308
- server .RegisterHandler ("/v1/completions" , func (w http.ResponseWriter , r * http.Request ) {
308
+ server .RegisterHandler ("/v1/completions" , func (http.ResponseWriter , * http.Request ) {
309
309
time .Sleep (10 * time .Nanosecond )
310
310
})
311
311
ctx := context .Background ()
0 commit comments