Skip to content

Commit 0bbac2b

Browse files
authored
Merge pull request #24 from petragabriela/feat/error-consumer
feat: add missing error consumer setter on connector
2 parents 6ca88ab + 90dd9d6 commit 0bbac2b

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.keepAliveIntervalMs = interval * 1000;

0 commit comments

Comments
 (0)