diff --git a/native/org.eclipse.cdt.native.serial/src/org/eclipse/cdt/serial/SerialPort.java b/native/org.eclipse.cdt.native.serial/src/org/eclipse/cdt/serial/SerialPort.java
index abbeacb5f9b..8b49cf9e676 100644
--- a/native/org.eclipse.cdt.native.serial/src/org/eclipse/cdt/serial/SerialPort.java
+++ b/native/org.eclipse.cdt.native.serial/src/org/eclipse/cdt/serial/SerialPort.java
@@ -103,21 +103,38 @@ public class SerialPort {
 					rpos += n;
 					return n;
 				} else {
-					n = read1(handle, b, off, len);
-					if (n <= 0 && isPaused) {
-						synchronized (pauseMutex) {
-							while (isPaused) {
-								try {
-									pauseMutex.wait();
-								} catch (InterruptedException e) {
-									return -1;
+					while (isOpen()) {
+						n = read1(handle, b, off, len);
+						if (n <= 0 ) {
+							if (isPaused) {
+								synchronized (pauseMutex) {
+									while (isPaused) {
+										try {
+											pauseMutex.wait();
+										} catch (InterruptedException e) {
+											return -1;
+										}
+									}
 								}
 							}
+							else if (n < 0) {
+								// End of stream, connection closed?
+								return n;
+							}
+							else {
+								// Nothing available yet, keep blocking
+								try {
+									Thread.sleep(500);
+								} catch (InterruptedException e) {
+									// ignore
+								}
+							}
+						} else {
+							return n;
 						}
-						return read1(handle, b, off, len);
-					} else {
-						return n;
 					}
+					
+					return -1;
 				}
 			} else {
 				return -1;