Skip to content
This repository was archived by the owner on Jan 27, 2023. It is now read-only.

Commit 9f98496

Browse files
committed
add raise if error back in to put stream
1 parent b45cc9b commit 9f98496

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

lib/cipherstash/client/rpc.rb

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -278,6 +278,9 @@ def put_stream(collection, records)
278278
unless res.is_a?(Documents::StreamingPutReply)
279279
raise Error::StreamingPutFailure, "expected Documents::StreamingPutReply response, got #{res.class} instead"
280280
end
281+
282+
raise_if_error(res)
283+
281284
@logger.debug("Cipherstash::Client::RPC#put_stream") { "#{res.numInserted} records inserted." }
282285

283286
num_inserted = res.numInserted

0 commit comments

Comments
 (0)