Skip to content

Commit 6a9c75c

Browse files
committed
refactor: remove unnecessary logging in QueryRef and WebSocketTransport classes
1 parent 90d2e1f commit 6a9c75c

File tree

2 files changed

+0
-11
lines changed

2 files changed

+0
-11
lines changed

packages/firebase_data_connect/firebase_data_connect/lib/src/core/ref.dart

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -432,8 +432,6 @@ class QueryRef<Data, Variables> extends OperationRef<Data, Variables> {
432432
void publishResultToStream(QueryResult<Data, Variables> result) {
433433
if (_streamController != null) {
434434
_streamController?.add(result);
435-
} else {
436-
log("QueryRef $operationId _streamFromServer loop _streamController is null");
437435
}
438436
}
439437

packages/firebase_data_connect/firebase_data_connect/lib/src/network/websocket_transport.dart

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,6 @@ class WebSocketTransport implements DataConnectTransport {
150150
if (_channel == null) return;
151151
final encoded = jsonEncode(json);
152152
if (encoded.isNotEmpty) {
153-
developer.log("Sending stream message \n $encoded");
154153
_channel!.sink.add(encoded);
155154
}
156155
}
@@ -229,7 +228,6 @@ class WebSocketTransport implements DataConnectTransport {
229228
} else {
230229
bodyString = message as String;
231230
}
232-
developer.log("Received stream response \n $bodyString");
233231

234232
final bodyJson = jsonDecode(bodyString) as Map<String, dynamic>;
235233
final response = StreamResponse.fromJson(bodyJson);
@@ -309,8 +307,6 @@ class WebSocketTransport implements DataConnectTransport {
309307
Timer? _reconnectTimer;
310308

311309
void _scheduleReconnect() {
312-
developer.log(
313-
'${DateTime.now()} _scheduleReconnect $_reconnectAttempts $_isReconnecting $_isExpectedDisconnect');
314310
if (_isReconnecting || _isExpectedDisconnect) return;
315311
_isReconnecting = true;
316312

@@ -323,13 +319,9 @@ class WebSocketTransport implements DataConnectTransport {
323319
final delay = min(
324320
_initialReconnectDelayMs * pow(2, _reconnectAttempts).toInt(),
325321
_maxReconnectDelayMs);
326-
var startTime = DateTime.now();
327-
developer.log('$startTime scheduling _performReconnect in $delay ms');
328322

329323
_reconnectTimer?.cancel();
330324
_reconnectTimer = Timer(Duration(milliseconds: delay), () async {
331-
developer.log(
332-
'${DateTime.now()} calling delayed _performReconnect scheduled at $startTime');
333325
_performReconnect();
334326
});
335327
}
@@ -443,7 +435,6 @@ class WebSocketTransport implements DataConnectTransport {
443435

444436
void _onDone() {
445437
if (_channel == null) return;
446-
developer.log('WebSocket connection closed.');
447438
_channel = null;
448439
_isReconnecting = false;
449440
if (!_isExpectedDisconnect) {

0 commit comments

Comments
 (0)