             },
                 thenRead: { _, _ in XCTFail("Should not read") })
             let recorder = publisher.record()
-            let recording = try wait(for: recorder.recording, timeout: 1)
+            let recording = try wait(for: recorder.recording, timeout: 5)
             XCTAssertTrue(recording.output.isEmpty)
             assertFailure(recording.completion) { (error: DatabaseError) in
                 XCTAssertEqual(error.resultCode, .SQLITE_ERROR)

                    updates: { db in try Player(id: 1, name: "Arthur", score: 1000).insert(db) },
                    thenRead: { db, _ in try Player.fetchCount(db) })
            let recorder = publisher.record()
            let count = try wait(for: recorder.single, timeout: 1)
            XCTAssertEqual(count, 1)
        }
        

                updates: { db in try db.execute(sql: "THIS IS NOT SQL") },
                thenRead: { _, _ in XCTFail("Should not read") })
            let recorder = publisher.record()
            let recording = try wait(for: recorder.recording, timeout: 5)
            XCTAssertTrue(recording.output.isEmpty)
            assertFailure(recording.completion) { (error: DatabaseError) in
                XCTAssertEqual(error.resultCode, .SQLITE_ERROR)
