diff --git a/src/pq/connection.cr b/src/pq/connection.cr
index cebc5f22..017a6984 100644
--- a/src/pq/connection.cr
+++ b/src/pq/connection.cr
@@ -267,6 +267,15 @@ module PQ
 
     def read_next_row_start
       type = soc.read_char
+
+      if type == 'N'
+        frame = read_one_frame type
+        async_frames = handle_async_frames frame
+        if async_frames
+          type = soc.read_char
+        end
+      end
+           
       if type == 'D'
         true
       else