(request_iterator,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None)
| 590 | |
| 591 | @staticmethod |
| 592 | def CreateNodeStream(request_iterator, |
| 593 | target, |
| 594 | options=(), |
| 595 | channel_credentials=None, |
| 596 | call_credentials=None, |
| 597 | insecure=False, |
| 598 | compression=None, |
| 599 | wait_for_ready=None, |
| 600 | timeout=None, |
| 601 | metadata=None): |
| 602 | return grpc.experimental.stream_stream( |
| 603 | request_iterator, |
| 604 | target, |
| 605 | '/tree.NodeReceiverStream/CreateNodeStream', |
| 606 | cells__tree__pb2.CreateNodeRequest.SerializeToString, |
| 607 | cells__tree__pb2.CreateNodeResponse.FromString, |
| 608 | options, |
| 609 | channel_credentials, |
| 610 | insecure, |
| 611 | call_credentials, |
| 612 | compression, |
| 613 | wait_for_ready, |
| 614 | timeout, |
| 615 | metadata, |
| 616 | _registered_method=True) |
| 617 | |
| 618 | @staticmethod |
| 619 | def UpdateNodeStream(request_iterator, |
nothing calls this directly
no outgoing calls
no test coverage detected