Skip to content

Commit 90dd9d6

Browse files
committed
feat: add missing error consumer setter on connector
1 parent f31cc6e commit 90dd9d6

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

lib/rsocket_connector.dart

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,11 @@ class RSocketConnector {
3737
return this;
3838
}
3939

40+
RSocketConnector errorConsumer(ErrorConsumer errorConsumer) {
41+
_errorConsumer = errorConsumer;
42+
return this;
43+
}
44+
4045
// set the keep alive, and unit is second
4146
RSocketConnector keepAlive(int interval, int maxLifeTime) {
4247
this.keepAliveInterval = interval;

0 commit comments

Comments
 (0)