File tree Expand file tree Collapse file tree 1 file changed +12
-9
lines changed
Expand file tree Collapse file tree 1 file changed +12
-9
lines changed Original file line number Diff line number Diff line change @@ -1188,16 +1188,19 @@ where
11881188 channel_id,
11891189 counterparty_node_id,
11901190 ) ;
1191- self . event_queue
1192- . add_event ( Event :: ChannelReady {
1193- channel_id,
1194- user_channel_id : UserChannelId ( user_channel_id) ,
1195- counterparty_node_id : Some ( counterparty_node_id) ,
1196- } )
1197- . unwrap_or_else ( |e| {
1191+
1192+ let event = Event :: ChannelReady {
1193+ channel_id,
1194+ user_channel_id : UserChannelId ( user_channel_id) ,
1195+ counterparty_node_id : Some ( counterparty_node_id) ,
1196+ } ;
1197+ match self . event_queue . add_event ( event) {
1198+ Ok ( _) => { } ,
1199+ Err ( e) => {
11981200 log_error ! ( self . logger, "Failed to push to event queue: {}" , e) ;
1199- panic ! ( "Failed to push to event queue" ) ;
1200- } ) ;
1201+ return Err ( ReplayEvent ( ) ) ;
1202+ } ,
1203+ } ;
12011204 } ,
12021205 LdkEvent :: ChannelClosed {
12031206 channel_id,
You can’t perform that action at this time.
0 commit comments