ehmry
/
syndicate_utils
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Replace dropType with matchType

This commit is contained in:
Emery Hemingway 2024-06-25 18:36:01 +03:00
parent 152fb258f3
commit 553e5cb7a9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/syndesizer/http_driver.nim
View File

@ -14,12 +14,12 @@ import
proc spawnHttpDriver*(turn: Turn; relay: Cap): Actor {.discardable.} = proc spawnHttpDriver*(turn: Turn; relay: Cap): Actor {.discardable.} =
## Create a dataspace for the driver and to the gatekeeper dance. ## Create a dataspace for the driver and to the gatekeeper dance.
spawnActor(turn, "http-driver") do (turn: Turn): spawnActor(turn, "http-driver") do (turn: Turn):
let pat = Resolve?:{ 0: HttpDriverStep.dropType } let pat = Resolve?:{ 0: HttpDriverStep.matchType }
during(turn, relay, pat): during(turn, relay, pat):
let ds = turn.newDataspace() let ds = turn.newDataspace()
http_driver.spawnHttpDriver(turn, ds) http_driver.spawnHttpDriver(turn, ds)
# Spawn a shared driver. # Spawn a shared driver.
let pat = Resolve?:{ 0: HttpDriverStep.dropType, 1: grab() } let pat = Resolve?:{ 0: HttpDriverStep.matchType, 1: grab() }
during(turn, relay, pat) do (obs: Cap): during(turn, relay, pat) do (obs: Cap):
discard publish(turn, obs, ResolvedAccepted(responderSession: ds)) discard publish(turn, obs, ResolvedAccepted(responderSession: ds))
# Pass the shared driver dataspace. # Pass the shared driver dataspace.