(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler)
| 162 | } |
| 163 | |
| 164 | func StreamServerInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error { |
| 165 | wrapped := grpc_middleware.WrapServerStream(ss) |
| 166 | wrapped.WrappedContext = context.WithValue(ss.Context(), &mockKey2{}, "foo") |
| 167 | return handler(srv, wrapped) |
| 168 | } |
| 169 | |
| 170 | func (s *mockServer) Subscribe(ids *ttnpb.ApplicationIdentifiers, srv ttnpb.AppAs_SubscribeServer) error { |
| 171 | s.subCtx, s.subIDs = srv.Context(), ids |