Init opens and verifies connection to database returns struct that holds connection and database.

NewSubscriptionsMux starts a collection watch, instantiate a new subscription muxer which handles watchChanges, subscription management and sending updates.

PollingInterval is the interval at which the subscription query is reevaluated in order to catch documents missed because of time-based queries.

Db structure facilitates access to the database and opened connection to the passed uri.

SubscriptionsMux handles subscription management and sending updates.

GenericType is an interface that facilitates instantiating models and sending updates to streams.