Updated SammiClient
Fixed missing method being not set. Removed State.CLOSED check to disconnect and null the client variable Moved request_completed signal emit to after we clear headers, buffer disconnect client connection, and null out client variable.
This commit is contained in:
parent
9457488fa7
commit
4f949a7239
1 changed files with 6 additions and 6 deletions
|
|
@ -43,6 +43,7 @@ func request(method: Method, api_path: String, body: String) -> void:
|
||||||
|
|
||||||
self.query = api_path
|
self.query = api_path
|
||||||
self.body = body
|
self.body = body
|
||||||
|
self.method = method
|
||||||
self.client = StreamPeerTCP.new()
|
self.client = StreamPeerTCP.new()
|
||||||
self.client.connect_to_host(host, port)
|
self.client.connect_to_host(host, port)
|
||||||
self.state = State.CONNECTING
|
self.state = State.CONNECTING
|
||||||
|
|
@ -51,11 +52,6 @@ func _process(_delta: float) -> void:
|
||||||
if not client:
|
if not client:
|
||||||
return
|
return
|
||||||
|
|
||||||
if state == State.CLOSED:
|
|
||||||
client.disconnect_from_host()
|
|
||||||
client = null
|
|
||||||
return
|
|
||||||
|
|
||||||
client.poll()
|
client.poll()
|
||||||
if client.get_status() == StreamPeerTCP.Status.STATUS_CONNECTED and state == State.CONNECTING:
|
if client.get_status() == StreamPeerTCP.Status.STATUS_CONNECTED and state == State.CONNECTING:
|
||||||
state = State.REQUESTING
|
state = State.REQUESTING
|
||||||
|
|
@ -130,8 +126,12 @@ func _read_response() -> void:
|
||||||
buffer.append_array(chunk[1])
|
buffer.append_array(chunk[1])
|
||||||
else:
|
else:
|
||||||
response = SammiResponse.new(headers, buffer, query)
|
response = SammiResponse.new(headers, buffer, query)
|
||||||
request_completed.emit(response)
|
|
||||||
state = State.CLOSED
|
state = State.CLOSED
|
||||||
|
headers = []
|
||||||
|
buffer = []
|
||||||
|
client.disconnect_from_host()
|
||||||
|
client = null
|
||||||
|
request_completed.emit(response)
|
||||||
|
|
||||||
|
|
||||||
class SammiResponse:
|
class SammiResponse:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue