forkineye
diff --git a/‎ESPAsyncE131.cpp‎
Lines changed: 13 additions & 5 deletions b/‎ESPAsyncE131.cpp‎
Lines changed: 13 additions & 5 deletions
diff --git a/‎ESPAsyncE131.h‎
Lines changed: 5 additions & 2 deletions b/‎ESPAsyncE131.h‎
Lines changed: 5 additions & 2 deletions
@@ -42,13 +42,21 @@ ESPAsyncE131::ESPAsyncE131(uint8_t buffers) {
 //
 /////////////////////////////////////////////////////////
 
-bool ESPAsyncE131::begin(e131_listen_t type, uint16_t universe, uint8_t n) {
+bool ESPAsyncE131::begin(e131_listen_t type, uint16_t universe, uint8_t n)
+{
+    begin (type, E131_ListenPort, universe, n);
+}
+
+bool ESPAsyncE131::begin (e131_listen_t type, ESPAsyncE131PortId UdpPortId, uint16_t universe, uint8_t n)
+{
     bool success = false;
 
+    E131_ListenPort = UdpPortId;
+
     if (type == E131_UNICAST)
-        success = initUnicast();
+        success = initUnicast ();
     if (type == E131_MULTICAST)
-        success = initMulticast(universe, n);
+        success = initMulticast (universe, n);
 
     return success;
 }
@@ -63,7 +71,7 @@ bool ESPAsyncE131::initUnicast() {
     bool success = false;
     delay(100);
 
-    if (udp.listen(E131_DEFAULT_PORT)) {
+    if (udp.listen(E131_ListenPort)) {
         udp.onPacket(std::bind(&ESPAsyncE131::parsePacket, this,
                 std::placeholders::_1));
         success = true;
@@ -78,7 +86,7 @@ bool ESPAsyncE131::initMulticast(uint16_t universe, uint8_t n) {
     IPAddress address = IPAddress(239, 255, ((universe >> 8) & 0xff),
         ((universe >> 0) & 0xff));
 
-    if (udp.listenMulticast(address, E131_DEFAULT_PORT)) {
+    if (udp.listenMulticast(address, E131_ListenPort)) {
         ip4_addr_t ifaddr;
         ip4_addr_t multicast_addr;
 
 
@@ -128,6 +128,8 @@ typedef struct {
     unsigned long    last_seen;
 } e131_stats_t;
 
+typedef uint16_t ESPAsyncE131PortId;
+
 class ESPAsyncE131 {
  private:
     // Constants for packet validation
@@ -149,14 +151,15 @@ class ESPAsyncE131 {
     void parsePacket(AsyncUDPPacket _packet);
 
     void (*PacketCallback)(e131_packet_t* ReceivedData, void* UserInfo) = nullptr;
+    ESPAsyncE131PortId E131_ListenPort = E131_DEFAULT_PORT;
 
  public:
     e131_stats_t  stats;    // Statistics tracker
-
     ESPAsyncE131(uint8_t buffers = 1);
 
     // Generic UDP listener, no physical or IP configuration
-    bool begin(e131_listen_t type, uint16_t universe = 1, uint8_t n = 1);
+    bool begin (e131_listen_t type, uint16_t universe = 1, uint8_t n = 1);
+    bool begin (e131_listen_t type, ESPAsyncE131PortId UdpPortId, uint16_t universe, uint8_t n);
 
     // Ring buffer access
     inline bool isEmpty() { return pbuff->isEmpty(pbuff); }