Skip to content

Commit 79ca569

Browse files
committed
wip: sim sanitizer
1 parent 62909bb commit 79ca569

2 files changed

Lines changed: 2 additions & 8 deletions

File tree

firestore_sim/lib/src/firestore_sim_client.dart

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,7 @@ import 'package:tekartik_firebase/firebase_mixin.dart';
66
import 'package:tekartik_firebase_firestore/src/firestore_common.dart'; // ignore: implementation_imports
77
import 'package:tekartik_firebase_firestore_sim/firestore_sim_message.dart';
88
import 'package:tekartik_firebase_firestore_sim/src/firestore_sim_common.dart';
9-
import 'package:tekartik_firebase_sim/firebase_sim_client.dart';
10-
import 'package:tekartik_firebase_sim/rpc_message.dart';
9+
1110
import 'package:tekartik_firebase_sim/src/firebase_sim_client.dart'; // ignore: implementation_imports
1211
import 'package:tekartik_firebase_sim/src/firebase_sim_common.dart'; // ignore: implementation_imports
1312

@@ -369,15 +368,11 @@ class ServerSubscriptionSim<T> {
369368
int? id;
370369
final StreamController<T> _controller;
371370

372-
// register for notification during the query
373-
StreamSubscription<Notification>? notificationSubscription;
374-
375371
ServerSubscriptionSim(this._controller);
376372

377373
Stream<T> get stream => _controller.stream;
378374

379375
Future close() async {
380-
await notificationSubscription?.cancel();
381376
await _controller.close();
382377
}
383378

firestore_sim/pubspec.yaml

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,9 +10,8 @@ dependencies:
1010
tekartik_firebase_sim:
1111
git:
1212
url: https://github.com/tekartik/firebase.dart
13-
path: firebase_sim
1413
ref: dart3a
15-
version: '>=0.3.7'
14+
path: firebase_sim
1615
tekartik_firebase_firestore:
1716
git:
1817
url: https://github.com/tekartik/firebase_firestore.dart

0 commit comments

Comments
 (0)