diff --git a/lib/src/types/data_stream.dart b/lib/src/types/data_stream.dart
index a5963ff5..5bad8479 100644
--- a/lib/src/types/data_stream.dart
+++ b/lib/src/types/data_stream.dart
@@ -161,9 +161,17 @@ class DataStreamController<T extends DataStream_Chunk> {
 
   Future<void> close() => streamController.close();
 
-  void write(T chunk) => streamController.add(chunk);
+  void write(T chunk) {
+    if (!streamController.isClosed) {
+      streamController.add(chunk);
+    }
+  }
 
-  void error(DataStreamError error) => streamController.addError(error);
+  void error(DataStreamError error) {
+    if (!streamController.isClosed) {
+      streamController.addError(error);
+    }
+  }
 }
 
 class ByteStreamInfo extends BaseStreamInfo {