ShspPeer constructor

ShspPeer({
  1. required PeerInfo remotePeer,
  2. required IShspSocket socket,
  3. MessageCallback? messageCallback,
})

Implementation

ShspPeer(
    {required this.remotePeer,
    required this.socket,
    MessageCallback? messageCallback}) {

  if (messageCallback != null) {
    _messageCallback = messageCallback;
  } else {
    _messageCallback = MessageCallback();
  }
  _socketCallback = (record) {
    onMessage(
        record.msg,
        PeerInfo(
          address: record.rinfo.address,
          port: record.rinfo.port,
        ));
  };

  // Register this peer with the socket so it receives messages
  socket.setMessageCallback(remotePeer, _socketCallback);
}