1 USING: accessors assocs continuations effects io
2 io.encodings.binary io.servers.connection kernel
3 memoize namespaces parser sets sequences serialize
4 threads vocabs vocabs.parser words ;
8 SYMBOL: serving-vocabs V{ } clone serving-vocabs set-global
10 : do-rpc ( args word -- bytes )
11 [ execute ] curry with-datastack object>bytes ; inline
13 MEMO: mem-do-rpc ( args word -- bytes ) do-rpc ; inline
15 : process ( vocabspec -- ) vocab-words [ deserialize ] dip deserialize
16 swap at "executer" get execute( args word -- bytes ) write flush ;
18 : (serve) ( -- ) deserialize dup serving-vocabs get-global index
19 [ process ] [ drop ] if ;
21 : start-serving-vocabs ( -- ) [
22 <threaded-server> 5000 >>insecure binary >>encoding [ (serve) ] >>handler
23 start-server ] in-thread ;
25 : (service) ( -- ) serving-vocabs get-global empty? [ start-serving-vocabs ] when
26 current-vocab serving-vocabs get-global adjoin
28 in get [ vocab vocab-words [ stack-effect ] { } assoc-map-as ] curry
29 (( -- words )) define-inline ;
31 SYNTAX: service \ do-rpc "executer" set (service) ;
32 SYNTAX: mem-service \ mem-do-rpc "executer" set (service) ;
36 \ mem-do-rpc "memoize" word-prop [ delete-at ] curry each ]
37 append ] change-global