Skip to content

Commit 4b72617

Browse files
committed
fix test failures
1 parent ee7f2f6 commit 4b72617

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

lib/src/json_hub_protocol.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ class JsonHubProtocol implements HubProtocol {
3232
final hubMessages = <HubMessage?>[];
3333

3434
// ignore: unnecessary_null_comparison
35-
if (input != null) {
35+
if (input == null) {
3636
return hubMessages;
3737
}
3838

lib/src/transports/web_socket_transport.dart

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,12 +60,12 @@ class WebSocketTransport implements Transport {
6060

6161
url = url!.replaceFirst(RegExp(r'^http'), 'ws');
6262

63-
_channel = await platform.connect(Uri.parse(url), client: _client);
63+
_channel = await platform.connect(Uri.parse(url), client: _client!);
6464

6565
_logging!(LogLevel.information, 'WebSocket connected to $url.');
6666
opened = true;
6767

68-
_streamSubscription = _channel!.stream.listen((data) {
68+
_streamSubscription = _channel?.stream.listen((data) {
6969
var dataDetail = getDataDetail(data, _logMessageContent);
7070
_logging!(
7171
LogLevel.trace, '(WebSockets transport) data received. $dataDetail');

0 commit comments

Comments
 (0)