@@ -303,18 +303,6 @@ mapped(cast, 'end', State) ->
303303mapped (cast , {flow_link , OutHandle , Flow0 , RenewWhenBelow }, State0 ) ->
304304 State = send_flow_link (OutHandle , Flow0 , RenewWhenBelow , State0 ),
305305 {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- =======
318306mapped (cast , {flow_session , IncomingWindow , RenewWhenBelow }, State0 ) ->
319307 AutoFlow = case RenewWhenBelow of
320308 never -> never ;
@@ -324,8 +312,7 @@ mapped(cast, {flow_session, IncomingWindow, RenewWhenBelow}, State0) ->
324312 auto_flow = AutoFlow },
325313 send_flow_session (State ),
326314 {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 ) ->
329316 % % We receive the first end frame, reply and terminate.
330317 _ = send_end (State ),
331318 % TODO: send notifications for links?
0 commit comments