diff --git a/pjlib/src/pj/activesock.c b/pjlib/src/pj/activesock.c
index 1d65fe7..903de70 100644
--- a/pjlib/src/pj/activesock.c
+++ b/pjlib/src/pj/activesock.c
@@ -420,7 +420,8 @@
 	} else if (bytes_read <= 0 &&
 		   -bytes_read != PJ_STATUS_FROM_OS(OSERR_EWOULDBLOCK) &&
 		   -bytes_read != PJ_STATUS_FROM_OS(OSERR_EINPROGRESS) && 
-		   -bytes_read != PJ_STATUS_FROM_OS(OSERR_ECONNRESET)) 
+		   (asock->stream_oriented ||
+		    -bytes_read != PJ_STATUS_FROM_OS(OSERR_ECONNRESET))) 
 	{
 	    pj_size_t remainder;
 	    pj_bool_t ret;