 
     func fetchEntries(#streamId: String, paginationParams: PaginationParams) -> ColdSignal<PaginatedEntryCollection> {
         return ColdSignal { (sink, disposable) in
-            self.client.fetchContents(streamId, paginationParams: paginationParams, completionHandler: { (req, res, entries, error) -> Void in
+            let req = self.client.fetchContents(streamId, paginationParams: paginationParams, completionHandler: { (req, res, entries, error) -> Void in
                 if let e = error {
                     sink.put(.Error(e))
                 } else {

                    sink.put(.Completed)
                }
            })
        }
    }

    func fetchCategories() -> ColdSignal<[FeedlyKit.Category]> {
        return ColdSignal { (sink, disposable) in
            let c = self.client
            c.fetchCategories({ (req, res, categories, error) -> Void in
                if let e = error {
                    sink.put(.Error(e))
                } else {

                    sink.put(.Completed)
                }
            })
            disposable.addDisposable({ req.cancel() })
        }
    }

    func searchFeeds(query: SearchQueryOfFeed) -> ColdSignal<[Feed]> {
        return ColdSignal { (sink, disposable) in
            let req = self.client.searchFeeds(query, completionHandler: { (req, res, feedResults, error) -> Void in
                if let e = error {
                    sink.put(.Error(e))
                } else {
