| 19 | namespace tensorflow { |
| 20 | |
| 21 | const char* ToString(UntypedStreamingRPCState::Tag::TagType tag_type) { |
| 22 | switch (tag_type) { |
| 23 | case UntypedStreamingRPCState::Tag::TagType::kCallStarted: |
| 24 | return "kCallStarted"; |
| 25 | case UntypedStreamingRPCState::Tag::TagType::kRequestWriteCompleted: |
| 26 | return "kRequestWriteCompleted"; |
| 27 | case UntypedStreamingRPCState::Tag::TagType::kResponseReadCommpleted: |
| 28 | return "kResponseReadCommpleted"; |
| 29 | case UntypedStreamingRPCState::Tag::TagType::kCallFinished: |
| 30 | return "kCallFinished"; |
| 31 | } |
| 32 | } |
| 33 | |
| 34 | UntypedStreamingRPCState::Tag::Tag(UntypedStreamingRPCState* streaming_state, |
| 35 | Tag::TagType type) |
no outgoing calls
no test coverage detected