@@ -1230,8 +1230,8 @@ where
1230
1230
/// # use bitcoin::{ScriptBuf, Transaction};
1231
1231
/// # use bitcoin::secp256k1::PublicKey;
1232
1232
/// # use lightning::ln::channelmanager::AChannelManager;
1233
- /// use lightning::events::{Event, EventsProvider};
1234
- ///
1233
+ /// # use lightning::events::{Event, EventsProvider};
1234
+ /// #
1235
1235
/// # struct Wallet {}
1236
1236
/// # impl Wallet {
1237
1237
/// # fn create_funding_transaction(
@@ -1245,15 +1245,9 @@ where
1245
1245
/// # let channel_manager = channel_manager.get_cm();
1246
1246
/// let value_sats = 1_000_000;
1247
1247
/// let push_msats = 10_000_000;
1248
- /// let user_channel_id = 42;
1249
- ///
1250
- /// match channel_manager.create_channel(peer_id, value_sats, push_msats, user_channel_id, None, None) {
1251
- /// Ok(channel_id) => println!(
1252
- /// "Opening channel {} (user_channel_id: {})", channel_id, user_channel_id
1253
- /// ),
1254
- /// Err(e) => println!(
1255
- /// "Error opening channel (user_channel_id: {}): {:?}", user_channel_id, e
1256
- /// ),
1248
+ /// match channel_manager.create_channel(peer_id, value_sats, push_msats, 42, None, None) {
1249
+ /// Ok(channel_id) => println!("Opening channel {}", channel_id),
1250
+ /// Err(e) => println!("Error opening channel: {:?}", e),
1257
1251
/// }
1258
1252
///
1259
1253
/// // On the event processing thread
@@ -1262,30 +1256,24 @@ where
1262
1256
/// temporary_channel_id, counterparty_node_id, channel_value_satoshis, output_script,
1263
1257
/// user_channel_id, ..
1264
1258
/// } => {
1259
+ /// assert_eq!(user_channel_id, 42);
1265
1260
/// let funding_transaction = wallet.create_funding_transaction(
1266
1261
/// channel_value_satoshis, output_script
1267
1262
/// );
1268
1263
/// match channel_manager.funding_transaction_generated(
1269
1264
/// &temporary_channel_id, &counterparty_node_id, funding_transaction
1270
1265
/// ) {
1271
- /// Ok(()) => println!(
1272
- /// "Funding channel {} (user_channel_id: {})", temporary_channel_id,
1273
- /// user_channel_id
1274
- /// ),
1275
- /// Err(e) => println!(
1276
- /// "Error funding channel {} (user_channel_id: {}): {:?}", temporary_channel_id,
1277
- /// user_channel_id, e
1278
- /// ),
1266
+ /// Ok(()) => println!("Funding channel {}", temporary_channel_id),
1267
+ /// Err(e) => println!("Error funding channel {}: {:?}", temporary_channel_id, e),
1279
1268
/// }
1280
1269
/// },
1281
1270
/// Event::ChannelPending { channel_id, user_channel_id, former_temporary_channel_id, .. } => {
1282
- /// println!(
1283
- /// "Channel {} (user_channel_id: {}) pending confirmations; old channel id: {}",
1284
- /// channel_id, user_channel_id, former_temporary_channel_id.unwrap()
1285
- /// );
1271
+ /// assert_eq!(user_channel_id, 42);
1272
+ /// println!("Channel {} now {} pending", channel_id, former_temporary_channel_id.unwrap())
1286
1273
/// },
1287
1274
/// Event::ChannelReady { channel_id, user_channel_id, .. } => {
1288
- /// println!("Channel {} (user_channel_id: {}) ready", channel_id, user_channel_id);
1275
+ /// assert_eq!(user_channel_id, 42);
1276
+ /// println!("Channel {} ready", channel_id);
1289
1277
/// },
1290
1278
/// // ...
1291
1279
/// # _ => {},
@@ -1302,8 +1290,8 @@ where
1302
1290
/// ```
1303
1291
/// # use bitcoin::secp256k1::PublicKey;
1304
1292
/// # use lightning::ln::channelmanager::AChannelManager;
1305
- /// use lightning::events::{Event, EventsProvider};
1306
- ///
1293
+ /// # use lightning::events::{Event, EventsProvider};
1294
+ /// #
1307
1295
/// # fn is_trusted(counterparty_node_id: PublicKey) -> bool {
1308
1296
/// # // ...
1309
1297
/// # unimplemented!()
@@ -1327,14 +1315,8 @@ where
1327
1315
/// match channel_manager.accept_inbound_channel(
1328
1316
/// &temporary_channel_id, &counterparty_node_id, user_channel_id
1329
1317
/// ) {
1330
- /// Ok(()) => println!(
1331
- /// "Accepting channel {} (user_channel_id: {})", temporary_channel_id,
1332
- /// user_channel_id
1333
- /// ),
1334
- /// Err(e) => println!(
1335
- /// "Error accepting channel {} (user_channel_id: {}): {:?}", temporary_channel_id,
1336
- /// user_channel_id, e
1337
- /// ),
1318
+ /// Ok(()) => println!("Accepting channel {}", temporary_channel_id),
1319
+ /// Err(e) => println!("Error accepting channel {}: {:?}", temporary_channel_id, e),
1338
1320
/// }
1339
1321
/// },
1340
1322
/// // ...
@@ -1355,8 +1337,8 @@ where
1355
1337
/// # use bitcoin::secp256k1::PublicKey;
1356
1338
/// # use lightning::ln::ChannelId;
1357
1339
/// # use lightning::ln::channelmanager::AChannelManager;
1358
- /// use lightning::events::{Event, EventsProvider};
1359
- ///
1340
+ /// # use lightning::events::{Event, EventsProvider};
1341
+ /// #
1360
1342
/// # fn example<T: AChannelManager>(
1361
1343
/// # channel_manager: T, channel_id: ChannelId, counterparty_node_id: PublicKey
1362
1344
/// # ) {
@@ -1369,7 +1351,8 @@ where
1369
1351
/// // On the event processing thread
1370
1352
/// channel_manager.process_pending_events(&|event| match event {
1371
1353
/// Event::ChannelClosed { channel_id, user_channel_id, .. } => {
1372
- /// println!("Channel {} (user_channel_id: {}) closed", channel_id, user_channel_id);
1354
+ /// assert_eq!(user_channel_id, 42);
1355
+ /// println!("Channel {} closed", channel_id);
1373
1356
/// },
1374
1357
/// // ...
1375
1358
/// # _ => {},
0 commit comments