diff --git a/lib/rsocket_connector.dart b/lib/rsocket_connector.dart
index 8a70952..f2e217f 100644
--- a/lib/rsocket_connector.dart
+++ b/lib/rsocket_connector.dart
@@ -37,6 +37,11 @@ class RSocketConnector {
     return this;
   }
 
+  RSocketConnector errorConsumer(ErrorConsumer errorConsumer) {
+    _errorConsumer = errorConsumer;
+    return this;
+  }
+
   // set the keep alive, and unit is second
   RSocketConnector keepAlive(int interval, int maxLifeTime) {
     this.keepAliveInterval = interval;