Lines Matching refs:StreamMsg
87 type StreamMsg struct { struct
93 func (m *StreamMsg) Reset() { *m = StreamMsg{} } argument
94 func (m *StreamMsg) String() string { return proto.CompactTextString(m) } argument
95 func (*StreamMsg) ProtoMessage() {} argument
96 func (*StreamMsg) Descriptor() ([]byte, []int) { argument
100 func (m *StreamMsg) XXX_Unmarshal(b []byte) error { argument
103 func (m *StreamMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { argument
106 func (m *StreamMsg) XXX_Merge(src proto.Message) { argument
109 func (m *StreamMsg) XXX_Size() int { argument
112 func (m *StreamMsg) XXX_DiscardUnknown() { argument
152 proto.RegisterType((*StreamMsg)(nil), "grpc.testing.StreamMsg")
232 Recv() (*StreamMsg, error)
240 func (x *testDownstreamClient) Recv() (*StreamMsg, error) {
241 m := new(StreamMsg)
258 Send(*StreamMsg) error argument
267 func (x *testUpstreamClient) Send(m *StreamMsg) error {
292 Send(*StreamMsg) error argument
301 func (x *testBidiClient) Send(m *StreamMsg) error {
355 Send(*StreamMsg) error argument
363 func (x *testDownstreamServer) Send(m *StreamMsg) error {
373 Recv() (*StreamMsg, error)
385 func (x *testUpstreamServer) Recv() (*StreamMsg, error) {
386 m := new(StreamMsg)
399 Recv() (*StreamMsg, error)
411 func (x *testBidiServer) Recv() (*StreamMsg, error) {
412 m := new(StreamMsg)