Fix crash if connection is lost (#1)

Following electric-sheep-co/arduino-redis#33 (comment)
electric-sheep-co · Jan 2, 2021 · ae0a26e · ae0a26e
1 parent e5b5947
commit ae0a26e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/connection.c b/src/connection.c
@@ -55,7 +55,9 @@ RedisObject_t RedisConnection_getNextObject(RedisConnection_t conn)
         readBytes = read(conn, &typeChar, sizeof(typeChar));
     } while (readBytes == sizeof(typeChar) && (typeChar == -1 || typeChar == '\r' || typeChar == '\n'));
 
-    assert(readBytes == sizeof(typeChar));
+    // lost connection to server
+    if(readBytes != sizeof(typeChar))
+        return rObj;
 
     RedisObjectTypeMap_t *typeMapWalk = RedisConnection_getNextObject__parseMap;
     for (; typeMapWalk->type != RedisObjectType_InternalError && typeMapWalk->create != NULL; typeMapWalk++)