handlePush method

Future<void> handlePush(
  1. P2PStream stream,
  2. PeerId peerId
)

Implementation

Future<void> handlePush(P2PStream stream, PeerId peerId) async {
  _log.fine('IdentifyService.handlePush: SERVER received identify PUSH from ${stream.conn.remotePeer} (reported as $peerId) on stream ${stream.id()}');
  _log.finer('IdentifyService.handlePush: Setting deadline for PUSH stream from ${stream.conn.remotePeer}');
  stream.setDeadline(DateTime.now().add(timeout));
  try {
    await handleIdentifyResponse(stream, true);
  } catch (e) {
    // A push that fails, for example because the peer closes while it
    // pushes, changes nothing: handleIdentifyResponse reset the stream.
    _log.fine('IdentifyService.handlePush: Push from $peerId failed: $e');
  }
}