Companion changes to enabled testing after reaktivity/reaktor.java#35
PREPARE phase should create ring buffers for accepts and connects.
Each accept and connect location is of the form nukleus://[receiver]/streams/[sender].
An accept should trigger proactive creation of sender under streams directory of receiver nukleus simulated by k3po, containing the initial streams that will be received by k3po.
An connect should trigger proactive creation of receiver under streams directory of sender nukleus simulated by k3po, containing the reply streams that will be received by k3po.
Companion changes to enabled testing after reaktivity/reaktor.java#35
PREPARE
phase should create ring buffers foraccepts
andconnects
.Each
accept
andconnect
location is of the formnukleus://[receiver]/streams/[sender]
.An
accept
should trigger proactive creation ofsender
understreams
directory ofreceiver
nukleus simulated byk3po
, containing the initial streams that will be received byk3po
.An
connect
should trigger proactive creation ofreceiver
understreams
directory ofsender
nukleus simulated byk3po
, containing the reply streams that will be received byk3po
.