Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 5 additions & 2 deletions plotly/plotly/chunked_requests/chunked_request.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@


class Stream:
def __init__(self, server, port=80, headers={}):
def __init__(self, server, port=80, headers={}, url='/'):
''' Initialize a stream object and an HTTP Connection
with chunked Transfer-Encoding to server:port with optional headers.
'''
Expand All @@ -15,6 +15,7 @@ def __init__(self, server, port=80, headers={}):
self._server = server
self._port = port
self._headers = headers
self._url = url
self._connect()

def write(self, data, reconnect_on=('', 200, )):
Expand Down Expand Up @@ -60,8 +61,10 @@ def write(self, data, reconnect_on=('', 200, )):
msg = data
msglen = format(len(msg), 'x') # msg length in hex
# Send the message in chunk-encoded form
self._conn.sock.setblocking(1)
self._conn.send('{msglen}\r\n{msg}\r\n'
.format(msglen=msglen, msg=msg).encode('utf-8'))
self._conn.sock.setblocking(0)
except http_client.socket.error:
self._reconnect()
self.write(data)
Expand All @@ -75,7 +78,7 @@ def _connect(self):
headers = self._headers
self._conn = http_client.HTTPConnection(server, port)

self._conn.putrequest('POST', '/')
self._conn.putrequest('POST', self._url)
self._conn.putheader('Transfer-Encoding', 'chunked')
for header in headers:
self._conn.putheader(header, headers[header])
Expand Down
2 changes: 1 addition & 1 deletion plotly/version.py
Original file line number Diff line number Diff line change
@@ -1 +1 @@
__version__ = '1.4.11'
__version__ = '1.4.12'