esad

:- op(1200, xfx, <-->).

:- use_module(library(dcg/basics), [digit//1]).

conj_rev(Term, Term) :- \+ Term = (_, _).
conj_rev((Term1,Term2), (Term2, T)) :- conj_rev(Term1, T).

term_expansion(<-->(X, Y), T) :- conj_rev(Y, YRev), dcg_translate_rule(X --> YRev, T).
term_expansion(<-->(X, Y), T) :- dcg_translate_rule(X --> Y, T).

esad

:- module(delstreams).

ask(_, 0, _) :- throw(asked_closed_stream).
ask(El, Stream, Stream2) :- reset(Stream, El, Stream2), (Stream2 \= 0).

take(0, _) :- !.
take(N, S) :- N > 0, ask(El, S, S1), shift(El), succ(N1, N), take(N1, S1).

drop(0, S) :- !, call(S).
drop(N, S) :- N > 0, ask(_, S, S1), succ(N1, N), drop(N1, S1).

esad

:- module(csv_writer, [csv_write/3, csv_write_row/1, csv_flush/0]).

:- use_module(util, [rational_string/3, get_keypath_dict/3, rtrim/3]).

:- meta_predicate csv_write(+, +, 0).

csv_write(Path, Fields, Goal) :-
  open(Path, write, Out),
  maplist(term_to_atom, Fields, AtomFields),
  Row =.. [row | AtomFields],