@@ -40,7 +40,7 @@ def __init__(self,
40
40
stream_id ,
41
41
window_manager ,
42
42
connection ,
43
- send_cb ,
43
+ send_outstanding_data ,
44
44
recv_cb ,
45
45
close_cb ):
46
46
self .stream_id = stream_id
@@ -76,7 +76,7 @@ def __init__(self,
76
76
self ._conn = connection
77
77
78
78
# Save off a data callback.
79
- self ._send_cb = send_cb
79
+ self ._send_outstanding_data = send_outstanding_data
80
80
self ._recv_cb = recv_cb
81
81
self ._close_cb = close_cb
82
82
@@ -96,7 +96,7 @@ def send_headers(self, end_stream=False):
96
96
headers = self .get_headers ()
97
97
with self ._conn as conn :
98
98
conn .send_headers (self .stream_id , headers , end_stream )
99
- self ._send_cb ()
99
+ self ._send_outstanding_data ()
100
100
101
101
if end_stream :
102
102
self .local_closed = True
@@ -191,7 +191,7 @@ def receive_data(self, event):
191
191
conn .increment_flow_control_window (
192
192
increment , stream_id = self .stream_id
193
193
)
194
- self ._send_cb ()
194
+ self ._send_outstanding_data ()
195
195
196
196
def receive_end_stream (self , event ):
197
197
"""
@@ -291,7 +291,7 @@ def close(self, error_code=None):
291
291
else :
292
292
send = True
293
293
if send :
294
- self ._send_cb (tolerate_peer_gone = True )
294
+ self ._send_outstanding_data (tolerate_peer_gone = True )
295
295
self .remote_closed = True
296
296
self .local_closed = True
297
297
@@ -333,7 +333,7 @@ def _send_chunk(self, data, final):
333
333
conn .send_data (
334
334
stream_id = self .stream_id , data = data , end_stream = end_stream
335
335
)
336
- self ._send_cb ()
336
+ self ._send_outstanding_data ()
337
337
338
338
if end_stream :
339
339
self .local_closed = True
0 commit comments