             default:
                 return nil
             }
-        }.unwrap().publish()
+        }.unwrap()
     }
     
     private func longpollAndPull() -> Observable<Changeset> {

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

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