diff --git a/src/esqlite3.erl b/src/esqlite3.erl index 5b69c83..b21debc 100644 --- a/src/esqlite3.erl +++ b/src/esqlite3.erl @@ -220,8 +220,11 @@ try_multi_step(Statement, ChunkSize, Rest, Tries) -> erlang:display({"busy", Tries}), timer:sleep(100 * Tries), try_multi_step(Statement, ChunkSize, Rows ++ Rest, Tries + 1); - {Status, Rows} -> - {Status, Rows ++ Rest} + {rows, Rows} -> + {rows, Rows ++ Rest}; + {'$done', Rows} -> + {'$done', Rows ++ Rest}; + Else -> Else end. %% @doc Execute Sql statement, returns the number of affected rows.