A simple demonstration of using fibers for annotation scheme

fibers_demo.scm

(define (atomese->graph in out)
    (define (expr->graph thing)
        (match (cog-type thing)
                ;; nodes
                ((or 'PredicateNode
                        'GeneNode
                        'MoleculeNode 'ConceptNode)  (format #f "~s~%" (cog-name thing)))


                ;; links
                ((or 'ListLink 'SetLink 'AndLink OrLink 'MemberLink 'EvaluationLink 'InheritanceLink)
                    (format #f "~s~%|~%~/~{~s ~}~%" (cog-type thing) (map expr->graph (cog-outgoing-set thing))))

                ;; This shouldn't happen
                (unknown #f))
    )

    (let loop ()
        (put-message out (expr->graph (get-message in)))
        (loop)
    )
)

(define (generate-result atoms out)
    (for-each (lambda (atom)
        (put-message out atom))
        atoms
    )
)

(define (write-to-file in port)
    (let loop ()
        (put-string port (get-message in))
        (loop)
    )
)

(define (main) (run-fibers (lambda ()
    (let (
        [ch1 (make-channel)]
        [ch2 (make-channel)]
        [port (open-output-file "/opt/annotation-scheme/test.txt")]
    )
    (spawn-fiber (lambda () (atomese->graph ch1 ch2)))
    (spawn-fiber (lambda () (write-to-file ch2 port)))

    (generate-result sample-atoms ch1)
    (close-port port)
    )

)))

(define sample-atoms (list 
    (EvaluationLink 
	 (PredicateNode "has_name")
	 (ListLink 
		 (ConceptNode "GO:0015219")
		 (ConceptNode "protein-DNA complex transmembrane transporter activity")))
(EvaluationLink 
	 (PredicateNode "has_name")
	 (ListLink 
		 (ConceptNode "GO:1902084")
		 (ConceptNode "fumagillin metabolic process"))))