diff options
| author |  Nathaniel Manista <nathaniel@google.com> | 2015-09-05 02:46:08 +0000 |
|---|---|---|
| committer | Nathaniel Manista <nathaniel@google.com> | 2015-09-05 02:46:43 +0000 |
| commit | 41abb052b8ed180ca14b9ff1427a215b8e4dcd60 (patch) | |
| tree | bbba3a18aacfec705f16f79144ac38a9ded65ca4 /src/python/grpcio/grpc/_adapter/fore.py | |
| parent | 13db8e517dd390cb1ede0146f5b0182e5f1e4dd5 (diff) | |
gRPC protocol objects
Diffstat (limited to 'src/python/grpcio/grpc/_adapter/fore.py')
| -rw-r--r-- | src/python/grpcio/grpc/_adapter/fore.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/python/grpcio/grpc/_adapter/fore.py b/src/python/grpcio/grpc/_adapter/fore.py index daa41e8bde..acdd69c420 100644 --- a/src/python/grpcio/grpc/_adapter/fore.py +++ b/src/python/grpcio/grpc/_adapter/fore.py @@ -56,7 +56,7 @@ class _LowWrite(enum.Enum): def _write(call, rpc_state, payload): serialized_payload = rpc_state.serializer(payload) if rpc_state.write.low is _LowWrite.OPEN: - call.write(serialized_payload, call) + call.write(serialized_payload, call, 0) rpc_state.write.low = _LowWrite.ACTIVE else: rpc_state.write.pending.append(serialized_payload) @@ -164,7 +164,7 @@ class ForeLink(base_interfaces.ForeLink, activated.Activated): if rpc_state.write.pending: serialized_payload = rpc_state.write.pending.pop(0) - call.write(serialized_payload, call) + call.write(serialized_payload, call, 0) elif rpc_state.write.high is _common.HighWrite.CLOSED: _status(call, rpc_state) else: |