Thanks Qi, I'll look into that.
If it helps anyone the wrapper looks like this:
type serverStreamWrapper struct {
ss grpc.ServerStream
ctx context.Context
}
func (w serverStreamWrapper) Context() context.Context { return
w.ctx }
func (w serverStreamWrapper) RecvMsg(msg interface{}) error { return
w.ss.RecvMsg(msg) }
func (w serverStreamWrapper) SendMsg(msg interface{}) error { return
w.ss.SendMsg(msg) }
func (w serverStreamWrapper) SendHeader(md metadata.MD) error { return
w.ss.SendHeader(md) }
func (w serverStreamWrapper) SetHeader(md metadata.MD) error { return
w.ss.SetHeader(md) }
func (w serverStreamWrapper) SetTrailer(md metadata.MD) {
w.ss.SetTrailer(md) }
On Thursday, November 10, 2016 at 4:28:05 PM UTC-6, Francesco Lazzarino
wrote:
>
> Hi,
>
> I'm implementing a StreamServerInterceptor.
>
> func StreamServerInterceptor(srv interface{}, ss grpc.ServerStream, info
> *grpc.StreamServerInfo, handler grpc.StreamHandler) error {
> // do some stuff, like attach a tracer to the context
> return handler(srv, ss)
> }
>
> I can read the inbound ctx from ss.Context() but I can't figure out a way
> to replace it on the stream with a derivative Context. The best I can thing
> of is to wrap ss with some other grpc.ServerStream that does what I want.
> Is this the canonical way to do this?
>
> Thanks,
>
> -Franco
>
--
You received this message because you are subscribed to the Google Groups
"grpc.io" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/grpc-io.
To view this discussion on the web visit
https://groups.google.com/d/msgid/grpc-io/11c15695-8b30-497d-a7a9-c9da348c8797%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
