Skip to content

Commit 902a4fd

Browse files
authored
Merge pull request #16 from marinkobabic/bugfix/fix_keepalive
time is in seconds
2 parents 8e43f42 + 04546ab commit 902a4fd

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

lib/rsocket_connector.dart

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,10 @@
11
import 'dart:typed_data';
22

33
import 'core/rsocket_error.dart';
4-
import 'payload.dart';
5-
import 'rsocket.dart';
6-
74
import 'core/rsocket_requester.dart';
85
import 'duplex_connection.dart';
6+
import 'payload.dart';
7+
import 'rsocket.dart';
98

109
class RSocketConnector {
1110
Payload? payload;
@@ -48,8 +47,8 @@ class RSocketConnector {
4847
Future<RSocket> connect(String url) async {
4948
TcpChunkHandler handler = (Uint8List chunk) {};
5049
var connectionSetupPayload = ConnectionSetupPayload()
51-
..keepAliveInterval = keepAliveInterval * 1000
52-
..keepAliveMaxLifetime = keepAliveMaxLifeTime * 1000
50+
..keepAliveInterval = keepAliveInterval
51+
..keepAliveMaxLifetime = keepAliveMaxLifeTime
5352
..metadataMimeType = _metadataMimeType
5453
..dataMimeType = _dataMimeType
5554
..data = payload?.data

0 commit comments

Comments
 (0)