@@ -154,21 +154,21 @@ func TestExecuteBegin(t *testing.T) {
154154 t .Fatal (err )
155155 }
156156
157- requests := drainRequestsFromServer ( server .TestSpanner )
158- beginRequests := requestsOfType (requests , reflect .TypeOf (& spannerpb.BeginTransactionRequest {}))
157+ requests := server .TestSpanner . DrainRequestsFromServer ( )
158+ beginRequests := testutil . RequestsOfType (requests , reflect .TypeOf (& spannerpb.BeginTransactionRequest {}))
159159 if g , w := len (beginRequests ), 0 ; g != w {
160160 t .Fatalf ("begin requests count mismatch\n Got: %v\n Want: %v" , g , w )
161161 }
162- executeRequests := requestsOfType (requests , reflect .TypeOf (& spannerpb.ExecuteSqlRequest {}))
162+ executeRequests := testutil . RequestsOfType (requests , reflect .TypeOf (& spannerpb.ExecuteSqlRequest {}))
163163 if g , w := len (executeRequests ), 1 ; g != w {
164164 t .Fatalf ("execute requests count mismatch\n Got: %v\n Want: %v" , g , w )
165165 }
166166 request := executeRequests [0 ].(* spannerpb.ExecuteSqlRequest )
167167 if request .GetTransaction () == nil || request .GetTransaction ().GetBegin () == nil {
168168 t .Fatal ("missing begin transaction on ExecuteSqlRequest" )
169169 }
170- commitRequests := requestsOfType (requests , reflect .TypeOf (& spannerpb.CommitRequest {}))
171- rollbackRequests := requestsOfType (requests , reflect .TypeOf (& spannerpb.RollbackRequest {}))
170+ commitRequests := testutil . RequestsOfType (requests , reflect .TypeOf (& spannerpb.CommitRequest {}))
171+ rollbackRequests := testutil . RequestsOfType (requests , reflect .TypeOf (& spannerpb.RollbackRequest {}))
172172 if end == "commit" {
173173 if g , w := len (commitRequests ), 1 ; g != w {
174174 t .Fatalf ("commit requests count mismatch\n Got: %v\n Want: %v" , g , w )
0 commit comments