go0:-
  reconsult('http://www.binnetcorp.com/download/Jinni/netjinni/q8.pro'),
  go.

go00:-
  new_reader('http://www.binnetcorp.com/download/Jinni/netjinni/q8.pro',R),
  new_writer('temp.pro',W),
  discharge(R,W).
  
:-[q8].

go1:-
  unfolder_source(':-'(x(X),member(X,[1,2,3,4])),S),
  get(S,the(A)),
  println(a(A)),
  get(S,the(B)),
  println(a(B)),
  unfolder_source(B,SB),
  get(SB,the(AA)),
  println(aa(AA)),
  get(SB,the(BB)),
  println(bb(BB)).

go2:-
  unfolder_source(':-'(x(X),member(X,[1,2,3])),S),
  get(S,Answer),
  println(Answer).

go3:-
  unfolder_source(':-'(q(X),qs(X)),Solver),
  repeat,
    get(Solver,Answer),
    println(Answer),
  eq(Answer,no).

go4:-
  unfolder_source(':-'(ok,go1),Solver),
  get(Solver,Answer),
  println(Answer).

% end

xthe(X,G,A):-
   new_solver(X,G,Solver),
   get(Solver,Answer),
   xconvert(Answer,A),
   get(Solver,no).

xconvert(no,no).
xconvert(':-'(A,true),the(A)).

go5:-
  list_source([1,2,3],I1),
  list_source([4,5],I2),
  append_sources(I1,I2,I3),
  source_list(I3,Xs),
  println(Xs).

go5a:-
  list_source([1,2,3],I1),
  list_source([4,5],I2),
  list_source([6,7],I3),
  append_sources([I1,I2,I3],I4),
  source_list(I4,Xs),
  println(Xs).

go6:-
  list_source([1,2,3],I1),
  list_source([a,b,c],I2),
  compose_sources(I1,I2,I3),
  source_list(I3,Xs),
  println(Xs).

go7:-
  list_source([1,2,3],I),
  get(I,A),
  println(A),
  split_source(I,I1,I2),
  compose_sources(I1,I2,I3),
  source_list(I3,Xs),
  println(Xs).

perm([],[]).
perm([X|Xs],Zs):-
	perm(Xs,Ys),
	insert(X,Ys,Zs).

insert(X,Ys,[X|Ys]).
insert(X,[Y|Ys],[Y|Zs]):-
	insert(X,Ys,Zs).

nrev([],[]).
nrev([X|Xs],Zs):-nrev(Xs,Ys),append(Ys,[X],Zs).

% Naive reverse benchmark
bm(N):-ints(1,N,Is),println(N),nrev(Is,Rs),println(Rs).
pm(N):-ints(1,N,Is),println(N),perm(Is,Rs),println(Rs),fail.

go8:-
  clause_file_writer('example.txt',Writer),fprint_clause(Writer,example(one)),stop(Writer),
  file_clause_reader('example.txt',Reader),fread(Reader,X),stop(Reader),println(X).

go9:-list_source([1,2,3,4],S),
        source_lazy_list(S,LL),
        eq(LL,[X,Y,Z]),
        println([X,Y,Z]),
        discharge(S).

go10:-
   list_source([1,2,3],S),
   source_lazy_list(S,Xs),
   lazy_head(Xs,X),
   lazy_tail(Xs,Ys),
   lazy_head(Ys,Y),
   println([S,Z,Y]).


go11:-
  lazy_findall(X,member(X,[1,2,3,4]),LXs),
  lazy_element_of(LXs,A),
  lazy_element_of(LXs,B),
  println(LXs),
  println(pair(A,B)),
  fail.
go11:-
  println(end).

producer(Name,TC):-for(I,1,10),put(TC,from(Name,I)),println(put(Name,I)).

consumer(Name,TC):-for(_,1,10),collect(TC,the(X)),println(to(Name,X)).

go12:-
  hub(0,TC),
  bg(consumer(one,TC),_),
  bg(consumer(two,TC),_),
  bg(producer(three,TC),_),
  bg(producer(four,TC),_),
  println(main_here),
  %stop(TC),
  println(main_end).

go12a:-
  hub(0,TC),
  bg(producer(three,TC),_),
  bg(producer(four,TC),_),
  bg(consumer(one,TC),_),
  bg(consumer(two,TC),_),
  println(main_here),
  %stop(TC),
  println(main_end).
  
bug:-
  hub(0,H),
  bg(put(H,a),_),
  bg(put(H,b),_),
  bg(and(collect(H,R),println(R)),_),
  bg(and(collect(H,RR),println(RR)),_).

go12b:-
  hub(0,H),
  bg(call(put(H,a(1))),_),
  bg(call(put(H,b(2))),_),
  bg(and(collect(H,R),println(R)),_),
  bg(and(collect(H,RR),println(RR)),_).
  
  
  
go13:-
  answer_source(X,member(X,[1,2,3]),S1),
  list_source([a,b],S2),
  list_source([10,20],S3),
  compose_sources(S1,S2,C),
  compose_sources(C,S3,D),
  source_list(D,R),
  println(R).
  
go14:-
  answer_source(X,member(X,[1,2,3]),S1),
  list_source([a],S2),
  list_source([10,20],S3),
  merge_sources([S1,S2,S3],S),
  source_list(S,R),
  println(R).