| 40 | ) |
| 41 | |
| 42 | type asImplementation struct { |
| 43 | ttnpb.UnimplementedAppAsServer |
| 44 | |
| 45 | *component.Component |
| 46 | up chan *ttnpb.ApplicationUp |
| 47 | } |
| 48 | |
| 49 | func (as *asImplementation) Subscribe(id *ttnpb.ApplicationIdentifiers, stream ttnpb.AppAs_SubscribeServer) error { |
| 50 | if err := clusterauth.Authorized(stream.Context()); err != nil { |
nothing calls this directly
no outgoing calls
no test coverage detected