@@ -409,7 +409,7 @@ defmodule StreamTest do
409409 assert_received % DBConnection.LogEntry { } = entry
410410 assert entry . query . query == query
411411
412- assert { :ok , ^ query , % { command: :copy_stream , rows: nil , num_rows: :copy_stream } } =
412+ assert { :ok , ^ query , % { command: :copy_stream , rows: nil , num_rows: nil } } =
413413 entry . result
414414
415415 assert_received % DBConnection.LogEntry { } = entry
@@ -678,7 +678,7 @@ defmodule StreamTest do
678678 assert_received % DBConnection.LogEntry { } = entry
679679 assert entry . query . query == query_in
680680
681- assert { :ok , ^ query_in , % { command: :copy_stream , rows: nil , num_rows: :copy_stream } } =
681+ assert { :ok , ^ query_in , % { command: :copy_stream , rows: nil , num_rows: nil } } =
682682 entry . result
683683
684684 assert_received % DBConnection.LogEntry { } = entry
@@ -706,7 +706,7 @@ defmodule StreamTest do
706706 assert_received % DBConnection.LogEntry { } = entry
707707 assert entry . query . query == query_in
708708
709- assert { :ok , ^ query_in , % { command: :copy_stream , rows: nil , num_rows: :copy_stream } } =
709+ assert { :ok , ^ query_in , % { command: :copy_stream , rows: nil , num_rows: nil } } =
710710 entry . result
711711
712712 assert_received % DBConnection.LogEntry { } = entry
@@ -746,7 +746,7 @@ defmodule StreamTest do
746746 assert_received % DBConnection.LogEntry { } = entry
747747 assert entry . query . query == query_in
748748
749- assert { :ok , ^ query_in , % { command: :copy_stream , rows: nil , num_rows: :copy_stream } } =
749+ assert { :ok , ^ query_in , % { command: :copy_stream , rows: nil , num_rows: nil } } =
750750 entry . result
751751
752752 assert_received % DBConnection.LogEntry { } = entry
0 commit comments