@@ -264,34 +264,18 @@ func TestNewStreamWithRecvFirstResultSet(t *testing.T) {
264264 require .NoError (t , err )
265265 require .NotNil (t , result )
266266 require .EqualValues (t , 1 , tt .recvCounter )
267-
268- val , ok := result .(* streamResult )
269- if ! ok {
270- panic (fmt .Sprintf ("unsupported type conversion from %T to *streamResult" , val ))
271- }
272- require .EqualValues (t , 1 , val .nextResultSetCounter .Load ())
273-
267+ require .EqualValues (t , 1 , result .(* streamResult ).nextResultSetCounter .Load ())
274268 for i := range make ([]struct {}, 1000 ) {
275269 err = result .NextResultSetErr (tt .ctx )
276270 require .NoError (t , err )
277271 require .Equal (t , i + 1 , tt .recvCounter )
278-
279- val , ok := result .(* streamResult )
280- if ! ok {
281- panic (fmt .Sprintf ("unsupported type conversion from %T to *streamResult" , val ))
282- }
283- require .Equal (t , i + 2 , int (val .nextResultSetCounter .Load ()))
272+ require .Equal (t , i + 2 , int (result .(* streamResult ).nextResultSetCounter .Load ()))
284273 }
285274 err = result .NextResultSetErr (tt .ctx )
286275 require .ErrorIs (t , err , io .EOF )
287276 require .True (t , err == io .EOF ) //nolint:errorlint,testifylint
288277 require .Equal (t , 1001 , tt .recvCounter )
289-
290- valC , okC := result .(* streamResult )
291- if ! okC {
292- panic (fmt .Sprintf ("unsupported type conversion from %T to *streamResult" , valC ))
293- }
294- require .Equal (t , 1002 , int (valC .nextResultSetCounter .Load ()))
278+ require .Equal (t , 1002 , int (result .(* streamResult ).nextResultSetCounter .Load ()))
295279 }
296280 })
297281 }
0 commit comments