@@ -303,18 +303,6 @@ mapped(cast, 'end', State) ->
303
303
mapped (cast , {flow_link , OutHandle , Flow0 , RenewWhenBelow }, State0 ) ->
304
304
State = send_flow_link (OutHandle , Flow0 , RenewWhenBelow , State0 ),
305
305
{keep_state , State };
306
- <<<<<<< HEAD
307
- mapped (cast , {flow_session , Flow0 = # 'v1_0.flow' {incoming_window = {uint , IncomingWindow }}},
308
- # state {next_incoming_id = NII ,
309
- next_outgoing_id = NOI } = State ) ->
310
- Flow = Flow0 # 'v1_0.flow' {
311
- next_incoming_id = maybe_uint (NII ),
312
- next_outgoing_id = uint (NOI ),
313
- outgoing_window = ? UINT_OUTGOING_WINDOW },
314
- ok = send (Flow , State ),
315
- {keep_state , State # state {incoming_window = IncomingWindow }};
316
- mapped (cast , # 'v1_0.end' {error = Err }, State ) ->
317
- =======
318
306
mapped (cast , {flow_session , IncomingWindow , RenewWhenBelow }, State0 ) ->
319
307
AutoFlow = case RenewWhenBelow of
320
308
never -> never ;
@@ -324,8 +312,7 @@ mapped(cast, {flow_session, IncomingWindow, RenewWhenBelow}, State0) ->
324
312
auto_flow = AutoFlow },
325
313
send_flow_session (State ),
326
314
{keep_state , State };
327
- mapped (cast , # 'v1_0.end' {} = End , State ) ->
328
- >>>>>>> 35394625 a (Auto widen session incoming - window in AMQP 1.0 client )
315
+ mapped (cast , # 'v1_0.end' {error = Err }, State ) ->
329
316
% % We receive the first end frame, reply and terminate.
330
317
_ = send_end (State ),
331
318
% TODO: send notifications for links?
0 commit comments