@@ -6156,7 +6156,6 @@ count_received_messages0(Receiver, Count) ->
6156
6156
Count
6157
6157
end .
6158
6158
6159
- <<<<<<< HEAD
6160
6159
send_messages (Sender , Left , Settled ) ->
6161
6160
send_messages (Sender , Left , Settled , <<>>).
6162
6161
@@ -6181,7 +6180,8 @@ send_messages(Sender, Left, Settled, BodySuffix) ->
6181
6180
% % So, we must be defensive here and assume that the next amqp10_client:send/2 call might return {error, insufficient_credit}
6182
6181
% % again causing us then to really wait to receive a credited event (instead of just processing an old credited event).
6183
6182
send_messages (Sender , Left , Settled , BodySuffix )
6184
- =======
6183
+ end .
6184
+
6185
6185
send_until_remote_incoming_window_exceeded (Session , Address ) ->
6186
6186
{ok , Sender } = amqp10_client :attach_sender_link (Session , <<" sender" >>, Address , settled ),
6187
6187
ok = wait_for_credit (Sender ),
@@ -6202,7 +6202,6 @@ send_until_remote_incoming_window_exceeded0(Sender, Left) ->
6202
6202
{error , remote_incoming_window_exceeded = Reason } ->
6203
6203
ct :pal (" ~s : ~b messages left" , [Reason , Left ]),
6204
6204
ok
6205
- >>>>>>> 0 d34ef604 (Set a floor of zero for incoming - window )
6206
6205
end .
6207
6206
6208
6207
assert_link_credit_runs_out (_Sender , 0 ) ->
0 commit comments