(request_iterator,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None)
| 175 | |
| 176 | @staticmethod |
| 177 | def ReadNodeStream(request_iterator, |
| 178 | target, |
| 179 | options=(), |
| 180 | channel_credentials=None, |
| 181 | call_credentials=None, |
| 182 | insecure=False, |
| 183 | compression=None, |
| 184 | wait_for_ready=None, |
| 185 | timeout=None, |
| 186 | metadata=None): |
| 187 | return grpc.experimental.stream_stream( |
| 188 | request_iterator, |
| 189 | target, |
| 190 | '/tree.NodeProviderStreamer/ReadNodeStream', |
| 191 | cells__tree__pb2.ReadNodeRequest.SerializeToString, |
| 192 | cells__tree__pb2.ReadNodeResponse.FromString, |
| 193 | options, |
| 194 | channel_credentials, |
| 195 | insecure, |
| 196 | call_credentials, |
| 197 | compression, |
| 198 | wait_for_ready, |
| 199 | timeout, |
| 200 | metadata, |
| 201 | _registered_method=True) |
| 202 | |
| 203 | |
| 204 | class NodeChangesStreamerStub(object): |
nothing calls this directly
no outgoing calls
no test coverage detected