We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e6e6690 commit 23f30c2Copy full SHA for 23f30c2
lib/src/observable.dart
@@ -75,11 +75,15 @@ extension Streamable<T> on Query<T> {
75
};
76
}
77
78
- Stream<List<T>> findStream({int offset = 0, int limit = 0}) {
+ Stream<List<T>> findStream(
79
+ {@Deprecated('Use offset() instead') int offset = 0,
80
+ @Deprecated('Use limit() instead') int limit = 0}) {
81
_setup();
- return _Observable.controller.stream
- .where((e) => e == entityId)
82
- .map((_) => find(offset: offset, limit: limit));
+ return _Observable.controller.stream.where((e) => e == entityId).map((_) {
83
+ if (offset != 0) this.offset(offset);
84
+ if (limit != 0) this.limit(limit);
85
+ return find();
86
+ });
87
88
89
/// Use this for Query Property
0 commit comments