diff --git a/packages/dart_client/lib/src/api/websocket.dart b/packages/dart_client/lib/src/api/websocket.dart index a610c041..15102c6e 100644 --- a/packages/dart_client/lib/src/api/websocket.dart +++ b/packages/dart_client/lib/src/api/websocket.dart @@ -105,6 +105,9 @@ class WebSocket { set _connectionStatus(ConnectionStatus status) => _connectionStatusController.add(status); + /// The current connection status value + ConnectionStatus get connectionStatus => _connectionStatusController.value; + /// This notifies of connection status changes Stream get connectionStatusStream => _connectionStatusController.stream; diff --git a/packages/dart_client/test/src/api/channel_test.dart b/packages/dart_client/test/src/api/channel_test.dart index d83d6f12..3897eb04 100644 --- a/packages/dart_client/test/src/api/channel_test.dart +++ b/packages/dart_client/test/src/api/channel_test.dart @@ -1,6 +1,6 @@ import 'package:dio/dio.dart'; import 'package:dio/native_imp.dart'; -import 'package:flutter_test/flutter_test.dart'; +import 'package:test/test.dart'; import 'package:mockito/mockito.dart'; import 'package:stream_chat/src/api/requests.dart'; import 'package:stream_chat/src/client.dart'; diff --git a/packages/dart_client/test/src/api/requests_test.dart b/packages/dart_client/test/src/api/requests_test.dart index 3ad762a7..6f7324ed 100644 --- a/packages/dart_client/test/src/api/requests_test.dart +++ b/packages/dart_client/test/src/api/requests_test.dart @@ -1,4 +1,4 @@ -import 'package:flutter_test/flutter_test.dart'; +import 'package:test/test.dart'; import 'package:stream_chat/stream_chat.dart'; void main() { diff --git a/packages/dart_client/test/src/api/responses_test.dart b/packages/dart_client/test/src/api/responses_test.dart index df576ba4..bfd4e5a7 100644 --- a/packages/dart_client/test/src/api/responses_test.dart +++ b/packages/dart_client/test/src/api/responses_test.dart @@ -1,6 +1,6 @@ import 'dart:convert'; -import 'package:flutter_test/flutter_test.dart'; +import 'package:test/test.dart'; import 'package:stream_chat/src/api/responses.dart'; import 'package:stream_chat/src/models/device.dart'; import 'package:stream_chat/src/models/member.dart'; diff --git a/packages/dart_client/test/src/api/web_socket_stub_test.dart b/packages/dart_client/test/src/api/web_socket_stub_test.dart index 5de61b4a..e60706dc 100644 --- a/packages/dart_client/test/src/api/web_socket_stub_test.dart +++ b/packages/dart_client/test/src/api/web_socket_stub_test.dart @@ -1,4 +1,4 @@ -import 'package:flutter_test/flutter_test.dart'; +import 'package:test/test.dart'; import 'package:stream_chat/src/api/web_socket_channel_stub.dart'; void main() { diff --git a/packages/dart_client/test/src/api/websocket_test.dart b/packages/dart_client/test/src/api/websocket_test.dart index e5a88bd8..d9486477 100644 --- a/packages/dart_client/test/src/api/websocket_test.dart +++ b/packages/dart_client/test/src/api/websocket_test.dart @@ -1,6 +1,6 @@ import 'dart:async'; -import 'package:flutter_test/flutter_test.dart'; +import 'package:test/test.dart'; import 'package:logging/logging.dart'; import 'package:mockito/mockito.dart'; import 'package:stream_chat/src/api/connection_status.dart'; @@ -67,7 +67,7 @@ void main() { await ws.connect(); verify(connectFunc(computedUrl)).called(1); - expect(ws.connectionStatus.value, ConnectionStatus.connected); + expect(ws.connectionStatus, ConnectionStatus.connected); await streamController.close(); timer.cancel();