Method Subscribe

pkg/rpcserver/rpcserver_test.go:170–174

(ids *ttnpb.ApplicationIdentifiers, srv ttnpb.AppAs_SubscribeServer)

}

func (s *mockServer) Subscribe(ids *ttnpb.ApplicationIdentifiers, srv ttnpb.AppAs_SubscribeServer) error {
	s.subCtx, s.subIDs = srv.Context(), ids
	srv.Send(applicationUp)
	return nil
}

func (s *mockServer) DownlinkQueuePush(ctx context.Context, req *ttnpb.DownlinkQueueRequest) (*emptypb.Empty, error) {
	s.pushCtx, s.pushReq = ctx, req