global

def safe_yield_stream(stream, &block)
  stream.each do |msg|
    safe_yield(msg, &block)
  end
rescue Exception => e
  raise StatelyDB::Error.from(e)
end