File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -86,7 +86,7 @@ export var MongoObservable;
86
86
} ;
87
87
Collection . prototype . find = function ( selector , options ) {
88
88
var cursor = this . _collection . find . apply ( this . _collection , arguments ) ;
89
- return ObservableCursor . create ( cursor ) . publish ( ) . refCount ( ) ;
89
+ return ObservableCursor . create ( cursor ) ;
90
90
} ;
91
91
Collection . prototype . findOne = function ( selector , options ) {
92
92
return this . _collection . findOne . apply ( this . _collection , arguments ) ;
Original file line number Diff line number Diff line change @@ -242,7 +242,7 @@ var ObservableCursor = (function (_super) {
242
242
} ;
243
243
Collection . prototype . find = function ( selector , options ) {
244
244
var cursor = this . _collection . find . apply ( this . _collection , arguments ) ;
245
- return ObservableCursor . create ( cursor ) . publish ( ) . refCount ( ) ;
245
+ return ObservableCursor . create ( cursor ) ;
246
246
} ;
247
247
Collection . prototype . findOne = function ( selector , options ) {
248
248
return this . _collection . findOne . apply ( this . _collection , arguments ) ;
Original file line number Diff line number Diff line change @@ -142,7 +142,7 @@ export module MongoObservable {
142
142
} ) : ObservableCursor < T > {
143
143
const cursor = this . _collection . find . apply (
144
144
this . _collection , arguments ) ;
145
- return ObservableCursor . create < T > ( cursor ) . publish ( ) . refCount ( ) ;
145
+ return ObservableCursor . create < T > ( cursor ) ;
146
146
}
147
147
148
148
findOne ( selector ?: Selector | ObjectID | string , options ?: {
You can’t perform that action at this time.
0 commit comments