PeerConnection constructor

PeerConnection({
  1. required String address,
  2. required int port,
  3. required BitcoinNetwork network,
  4. PeerConnectionConfig? config,
  5. Logger? logger,
})

Implementation

PeerConnection({
  required this.address,
  required this.port,
  required this.network,
  PeerConnectionConfig? config,
  Logger? logger,
}) : config = config ?? const PeerConnectionConfig(),
     logger = logger ?? Logger('PeerConnection') {
  _messageProcessor = MessageProcessor(network: network, logger: logger);
  _outboundQueue = MessageQueue(config: this.config.queueConfig, logger: logger);

       // Log queue events
   _outboundQueue.droppedMessages.listen((msg) {
     this.logger.warning('Message dropped from queue: ${msg.message.command}');
   });
   _outboundQueue.expiredMessages.listen((msg) {
     this.logger.warning('Message expired in queue: ${msg.message.command}');
   });
}