     |> Writer.run
 
     assert [{:ok, _}] = results
+    :done = wait_for_replication(fourfour)
 
     {:ok, rows_stream} = Reader.query(fourfour)
     |> Reader.run
 
-    assert Enum.into(rows_stream, []) == [[{"text column", "a text value"}], [{"text column", "a second text value"}]]
-  end
-
-    test "can do a streaming upsert" do
+    assert Enum.into(rows_stream, []) == [[{"text_column", "a text value"}], [{"text_column", "a second text value"}]]
+  end
+
+  test "can do a streaming upsert" do
     [{:ok, %Response{body: %{"id" => fourfour}}}] = Writer.write()
     |> Writer.create("a name", %{description: "describes"})
     |> Writer.run

    UploadAttachment
  }

  test "can create a create_view operation" do
    w = Writer.write()
    |> Writer.create("a name", %{description: "describes"})


    assert [{:ok, _}] = results

    :done = wait_for_replication(fourfour)

    {:ok, rows_stream} = Reader.query(fourfour)
    |> Reader.run

    assert Enum.into(rows_stream, []) == [
      [{"text_column", "value 0"}],
      [{"text_column", "value 1"}],
      [{"text_column", "value 2"}],
      [{"text_column", "value 3"}],
      [{"text_column", "value 4"}],
      [{"text_column", "value 5"}],
      [{"text_column", "value 6"}],
      [{"text_column", "value 7"}],
      [{"text_column", "value 8"}]
    ]
  end

