@@ -406,7 +406,7 @@ defmodule GRPC.Integration.ServerTest do
406406 ]
407407 )
408408
409- assert_receive { :gun_response , ^ conn_pid , ^ stream_ref , :fin , ^ status , _headers }
409+ assert_receive { :gun_up , ^ conn_pid , :http }
410410 end
411411 end )
412412 end
@@ -459,7 +459,7 @@ defmodule GRPC.Integration.ServerTest do
459459 { "content-type" , "application/json" }
460460 ] )
461461
462- assert_receive { :gun_response , ^ conn_pid , ^ stream_ref , :nofin , 200 , _headers }
462+ assert_receive { :gun_up , ^ conn_pid , :http }
463463 assert { :ok , body } = :gun . await_body ( conn_pid , stream_ref )
464464
465465 assert % {
@@ -571,6 +571,7 @@ defmodule GRPC.Integration.ServerTest do
571571 Jason . encode! ( payload )
572572 )
573573
574+ assert_receive { :gun_up , ^ conn_pid , :http }
574575 assert_receive { :gun_response , ^ conn_pid , ^ stream_ref , :nofin , 200 , _headers }
575576 assert { :ok , body } = :gun . await_body ( conn_pid , stream_ref )
576577
@@ -582,6 +583,7 @@ defmodule GRPC.Integration.ServerTest do
582583 ] )
583584
584585 assert_receive { :gun_response , ^ conn_pid , ^ stream_ref , :nofin , 200 , _headers }
586+
585587 assert { :ok , body } = :gun . await_body ( conn_pid , stream_ref )
586588
587589 assert % {
0 commit comments