     
     public let forcePollCommand: ReplaySubject<Int> = ReplaySubject.createUnbounded()
     
-    var changesets: Observable<Changeset>!
+    var changesets: ConnectableObservable<Changeset>!
     var observable: ConnectableObservable<FilesystemEvent>!
     
     init(client: DropboxClient? = nil) {

    }
    
    func configure(client: DropboxClient) {
        self.client = client
        _ = self.observable.connect() // Start emitting events
    }
        
    func write(file: File<Data>) -> Observable<Path> {

            changes = pollLoop.startWith(Changeset(entries: [], cursor: cursor!))
        }
        
        self.changesets = changes.publish()
        
        self.observable =
            self.changesets
