An RxJS wrapper over Meteor MongoDB collections.

API

$3

``typescript
class ObservableCollection {
readonly collection: Mongo.Collection;
find: (selector?: Mongo.Selector | Mongo.ObjectID | string, options?: {
sort?: Mongo.SortSpecifier;
skip?: number;
limit?: number;
fields?: Mongo.FieldSpecifier;
reactive?: boolean;
transform?: Function;
}) => ObservableCursor;
findOne: (selector?: Mongo.Selector | Mongo.ObjectID | string, options?: {
sort?: Mongo.SortSpecifier;
skip?: number;
fields?: Mongo.FieldSpecifier;
reactive?: boolean;
transform?: Function;
}) => Observable;
update: (selector: Mongo.Selector | Mongo.ObjectID | string, modifier: Mongo.Modifier, options?: {
multi?: boolean;
upsert?: boolean;
}) => Observable;
upsert: (selector: Mongo.Selector | Mongo.ObjectID | string, modifier: Mongo.Modifier, options?: {
multi?: boolean;
}) => Observable<{
numberAffected?: number;
insertedId?: string;
}>;
constructor(collection: Mongo.Collection);
insert(document: T): Observable;
rawCollection(): any;
rawDatabase(): any;
remove(selector: Mongo.Selector | Mongo.ObjectID | string): Observable;
}

`

$3

`typescript
class ObservableCursor {
readonly cursor: Promise>;
count: (applySkipLimit?: boolean) => Observable;
constructor(cursor: Promise>);
fetch(): Observable;
observe(callbacks: ObservableCursorObserveCallbacks): Observable;
}
`

$3

`typescript
interface ObservableCursorObserveCallbacks {
initial?(documents: T[]): ObservableInput | void;
added?(document: T): ObservableInput | void;
addedAt?(document: T, atIndex: number, before: T): ObservableInput | void;
changed?(newDocument: T, oldDocument: T): ObservableInput | void;
changedAt?(newDocument: T, oldDocument: T, indexAt: number): ObservableInput | void;
removed?(oldDocument: T): ObservableInput | void;
removedAt?(oldDocument: T, atIndex: number): ObservableInput | void;
movedTo?(document: T, fromIndex: number, toIndex: number, before: T): ObservableInput | void;
}
``