 
     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"}]
+      [{"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
 

    |> Writer.run

    assert [{:ok, _}] = results

    {: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 add options to Upsert operation" do


    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

