Lines Matching defs:repClientStream

441 type repClientStream struct {  struct
442 	ctx    context.Context
443 	rep    *Replayer
444 	method string
445 	str    *stream
448 func (rcs *repClientStream) Context() context.Context { return rcs.ctx }
450 func (rcs *repClientStream) SendMsg(req interface{}) error {
466 func (rcs *repClientStream) setStream(method string, req proto.Message) error {
478 func (rcs *repClientStream) RecvMsg(m interface{}) error {
498 func (rcs *repClientStream) Header() (metadata.MD, error) {
503 func (rcs *repClientStream) Trailer() metadata.MD {
508 func (rcs *repClientStream) CloseSend() error {