Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
nitely committed Feb 27, 2024
1 parent 4d45023 commit 411844b
Show file tree
Hide file tree
Showing 2 changed files with 164 additions and 135 deletions.
10 changes: 5 additions & 5 deletions src/hyperx/client.nim
Original file line number Diff line number Diff line change
Expand Up @@ -293,13 +293,13 @@ proc sendRstStream(
func doTransitionRecv(s: var Stream, frm: Frame) {.raises: [ConnError, StrmError].} =
doAssert frm.sid.StreamId == s.id
doAssert frm.sid != frmSidMain
check frm.typ in frmRecvAllowed, newConnError(errProtocolError)
check frm.typ in frmStreamAllowed, newConnError(errProtocolError)
if not s.state.isAllowedToRecv frm:
if s.state == strmHalfClosedRemote:
raise newStrmError(errStreamClosed)
else:
raise newConnError(errProtocolError)
s.state = s.state.toNextStateRecv frm.toEventRecv()
s.state = s.state.toNextStateRecv frm.toStreamEvent()
check s.state != strmInvalid, newConnError(errProtocolError)
#if oldState == strmIdle:
# # XXX close streams < s.id in idle state
Expand Down Expand Up @@ -772,14 +772,14 @@ const
defaultAccept = "*/*"
defaultContentType = "application/json"

proc request*(
proc request(
client: ClientContext,
httpMethod: HttpMethod,
path: string,
data: seq[byte] = @[],
userAgent = defaultUserAgent,
accept = "",
contentType = ""
accept = defaultAccept,
contentType = defaultContentType
): Future[Response] {.async.} =
var req = newRequest()
client.addHeader(req, ":method", $httpMethod)
Expand Down
Loading

0 comments on commit 411844b

Please sign in to comment.