@@ -79,8 +79,8 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
79
79
}
80
80
81
81
let latestBlockHash = Bindings . LDKThirtyTwoBytes_to_array ( nativeType: channelManagerResult. cOpaqueStruct!. contents. result. pointee. a)
82
- let channelManager = ChannelManager ( pointer: channelManagerResult. dangle ( ) . cOpaqueStruct!. contents. result. pointee. b)
83
- // try! channelManager.addAnchor(anchor: channelManagerResult)
82
+ let channelManager = ChannelManager ( pointer: channelManagerResult. cOpaqueStruct!. contents. result. pointee. b)
83
+ try ! channelManager. dangle ( ) . addAnchor ( anchor: channelManagerResult)
84
84
85
85
86
86
self . channelManager = channelManager
@@ -169,25 +169,18 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
169
169
monitorClone. cOpaqueStruct? . is_owned = true
170
170
}
171
171
172
- let customPersister = CustomChannelManagerPersister ( handler: persister)
173
- let customEventHandler = CustomEventHandler ( handler: persister)
174
- /*self.backgroundProcessor = BackgroundProcessor(persister: self.customPersister!, event_handler: self.customEventHandler!, chain_monitor: self.chain_monitor, channel_manager: self.channelManager, peer_manager: self.peerManager, logger: self.logger)
175
- try! self.backgroundProcessor!.addAnchor(anchor: self.channelManager)
172
+ self . customPersister = CustomChannelManagerPersister ( handler: persister)
173
+ self . customEventHandler = CustomEventHandler ( handler: persister)
174
+ self . backgroundProcessor = BackgroundProcessor ( persister: self . customPersister!, event_handler: self . customEventHandler!, chain_monitor: self . chain_monitor, channel_manager: self . channelManager, peer_manager: self . peerManager, logger: self . logger)
176
175
try ! self . backgroundProcessor!. addAnchor ( anchor: self . peerManager)
177
- try! self.backgroundProcessor!.addAnchor(anchor: self.customPersister!)
178
- try! self.backgroundProcessor!.addAnchor(anchor: self.customEventHandler!)*/
179
176
180
177
}
181
178
182
179
public func interrupt( ) {
183
180
self . shutdown = true
184
181
self . backgroundProcessor? . stop ( )
185
- self . backgroundProcessor = nil
186
182
}
187
183
188
- deinit {
189
- print ( " channelmanagerconstructor destructor " )
190
- }
191
184
192
185
}
193
186
0 commit comments