@@ -375,7 +375,7 @@ defmodule GRPC.Integration.ServerTest do
375375 ]
376376 )
377377
378- assert_receive { :gun_response , ^ conn_pid , ^ stream_ref , :fin , ^ status , _headers }
378+ assert_receive { :gun_up , ^ conn_pid , :http }
379379 end
380380 end )
381381 end
@@ -428,7 +428,7 @@ defmodule GRPC.Integration.ServerTest do
428428 { "content-type" , "application/json" }
429429 ] )
430430
431- assert_receive { :gun_response , ^ conn_pid , ^ stream_ref , :nofin , 200 , _headers }
431+ assert_receive { :gun_up , ^ conn_pid , :http }
432432 assert { :ok , body } = :gun . await_body ( conn_pid , stream_ref )
433433
434434 assert % {
@@ -540,6 +540,7 @@ defmodule GRPC.Integration.ServerTest do
540540 Jason . encode! ( payload )
541541 )
542542
543+ assert_receive { :gun_up , ^ conn_pid , :http }
543544 assert_receive { :gun_response , ^ conn_pid , ^ stream_ref , :nofin , 200 , _headers }
544545 assert { :ok , body } = :gun . await_body ( conn_pid , stream_ref )
545546
@@ -551,6 +552,7 @@ defmodule GRPC.Integration.ServerTest do
551552 ] )
552553
553554 assert_receive { :gun_response , ^ conn_pid , ^ stream_ref , :nofin , 200 , _headers }
555+
554556 assert { :ok , body } = :gun . await_body ( conn_pid , stream_ref )
555557
556558 assert % {
0 commit comments