some formatting
parent
a041fb06dc
commit
536933fafc
|
@ -52,13 +52,12 @@ SYMBOL: mdb-instance
|
||||||
nodes>> [ f ] dip at inet>> ;
|
nodes>> [ f ] dip at inet>> ;
|
||||||
|
|
||||||
: with-db ( mdb quot: ( -- * ) -- * )
|
: with-db ( mdb quot: ( -- * ) -- * )
|
||||||
[ [ '[ _ [ mdb-instance set ensure-buffer ] keep master>>
|
[ [ '[ ensure-buffer _ [ mdb-instance set ] keep
|
||||||
[ remote-address set ] keep
|
master>> [ remote-address set ] keep
|
||||||
binary <client>
|
binary <client> local-address set
|
||||||
local-address set
|
|
||||||
mdb-socket-stream set ] ] dip compose
|
mdb-socket-stream set ] ] dip compose
|
||||||
[ mdb-stream>> [ dispose ] when* ] [ ] cleanup
|
[ mdb-stream>> [ dispose ] when* ]
|
||||||
] with-scope ; inline
|
[ ] cleanup ] with-scope ; inline
|
||||||
|
|
||||||
<PRIVATE
|
<PRIVATE
|
||||||
|
|
||||||
|
@ -189,7 +188,7 @@ MEMO: ensure-collection ( collection -- fq-collection )
|
||||||
GENERIC# limit 1 ( mdb-query limit# -- mdb-query )
|
GENERIC# limit 1 ( mdb-query limit# -- mdb-query )
|
||||||
M: mdb-query-msg limit ( query limit# -- mdb-query )
|
M: mdb-query-msg limit ( query limit# -- mdb-query )
|
||||||
>>return# ; inline
|
>>return# ; inline
|
||||||
|
|
||||||
GENERIC# skip 1 ( mdb-query skip# -- mdb-query )
|
GENERIC# skip 1 ( mdb-query skip# -- mdb-query )
|
||||||
M: mdb-query-msg skip ( query skip# -- mdb-query )
|
M: mdb-query-msg skip ( query skip# -- mdb-query )
|
||||||
>>skip# ; inline
|
>>skip# ; inline
|
||||||
|
|
Loading…
Reference in New Issue