(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None)
| 247 | |
| 248 | @staticmethod |
| 249 | def StreamChanges(request, |
| 250 | target, |
| 251 | options=(), |
| 252 | channel_credentials=None, |
| 253 | call_credentials=None, |
| 254 | insecure=False, |
| 255 | compression=None, |
| 256 | wait_for_ready=None, |
| 257 | timeout=None, |
| 258 | metadata=None): |
| 259 | return grpc.experimental.unary_stream( |
| 260 | request, |
| 261 | target, |
| 262 | '/tree.NodeChangesStreamer/StreamChanges', |
| 263 | cells__tree__pb2.StreamChangesRequest.SerializeToString, |
| 264 | cells__tree__pb2.NodeChangeEvent.FromString, |
| 265 | options, |
| 266 | channel_credentials, |
| 267 | insecure, |
| 268 | call_credentials, |
| 269 | compression, |
| 270 | wait_for_ready, |
| 271 | timeout, |
| 272 | metadata, |
| 273 | _registered_method=True) |
| 274 | |
| 275 | |
| 276 | class NodeChangesReceiverStreamerStub(object): |
nothing calls this directly
no outgoing calls
no test coverage detected