concurrency.distributed: use delete-at* instead of at/delete-at.
parent
0ac73e1f11
commit
c68f0e0042
|
@ -56,8 +56,8 @@ C: <connection> connection
|
||||||
[ thread-connections set-at ] bi ;
|
[ thread-connections set-at ] bi ;
|
||||||
|
|
||||||
: disconnect ( remote-thread -- )
|
: disconnect ( remote-thread -- )
|
||||||
[ thread-connections at [ stream>> dispose ] when* ]
|
thread-connections delete-at*
|
||||||
[ thread-connections delete-at ] bi ;
|
[ stream>> dispose ] [ drop ] if ;
|
||||||
|
|
||||||
: with-connection ( remote-thread quot -- )
|
: with-connection ( remote-thread quot -- )
|
||||||
'[ connect @ ] over [ disconnect ] curry [ ] cleanup ; inline
|
'[ connect @ ] over [ disconnect ] curry [ ] cleanup ; inline
|
||||||
|
|
Loading…
Reference in New Issue