test_class.declarator: active
test_class.original_string: ActiveResource active;
test_class.type: ActiveResource
test_class.var_name: active
test_class.declarator: queries1
test_class.original_string: RequestsBeingExecuted queries1;
test_class.type: RequestsBeingExecuted
test_class.var_name: queries1
test_class.declarator: queries2
test_class.original_string: RequestsBeingExecuted queries2;
test_class.type: RequestsBeingExecuted
test_class.var_name: queries2
test_class.declarator: jobs
test_class.original_string: JobsBeingExecuted jobs;
test_class.type: JobsBeingExecuted
test_class.var_name: jobs
test_class.declarator: bus
test_class.original_string: EventBus bus;
test_class.type: EventBus
test_class.var_name: bus
test_class.file: micro-events/src/test/java/com/oath/micro/server/rest/resources/ActiveResourceTest.java
test_class.identifier: ActiveResourceTest
test_case.body: @Test
      public void whenQueriesWithTheSameIdToDifferentTypesEventsIs1ForBoth() {
          bus.post(RequestEvents.start("query", "1"));
          bus.post(RequestEvents.start("query", "1", "partition", ImmutableMap.of()));
          MockAsyncResponse<String> response = new MockAsyncResponse<>();
          active.activeRequests(response, null);
          assertThat(convert(response.response()).get("events"), is(1));
          active.activeRequests(response, "partition");
          assertThat(convert(response.response()).get("events"), is(1));
      }
test_case.class_method_signature: ActiveResourceTest.whenQueriesWithTheSameIdToDifferentTypesEventsIs1ForBoth()
test_case.full_signature: @Test public void whenQueriesWithTheSameIdToDifferentTypesEventsIs1ForBoth()
test_case.identifier: whenQueriesWithTheSameIdToDifferentTypesEventsIs1ForBoth
test_case.invocations: post start post start of activeRequests assertThat get convert response is activeRequests assertThat get convert response is
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void whenQueriesWithTheSameIdToDifferentTypesEventsIs1ForBoth()
focal_class.declarator: LOG_LEVEL = null
focal_class.modifier: private static final
focal_class.original_string: private static final Object LOG_LEVEL = null;
focal_class.type: Object
focal_class.var_name: LOG_LEVEL
focal_class.declarator: activeQueries
focal_class.modifier: private final
focal_class.original_string: private final RequestTypes<T> activeQueries;
focal_class.type: RequestTypes<T>
focal_class.var_name: activeQueries
focal_class.declarator: activeJobs
focal_class.modifier: private final
focal_class.original_string: private final JobsBeingExecuted activeJobs;
focal_class.type: JobsBeingExecuted
focal_class.var_name: activeJobs
focal_class.declarator: entityIds
focal_class.modifier: private
focal_class.original_string: private Long entityIds;
focal_class.type: Long
focal_class.var_name: entityIds
focal_class.file: micro-events/src/main/java/com/oath/micro/server/rest/resources/ActiveResource.java
focal_class.identifier: ActiveResource
focal_class.interfaces: implements CommonRestResource, SingletonRestResource
focal_class.class_method_signature: ActiveResource.ActiveResource(RequestTypes<T> activeQueries, JobsBeingExecuted activeJobs)
focal_class.full_signature: @Autowired public  ActiveResource(RequestTypes<T> activeQueries, JobsBeingExecuted activeJobs)
focal_class.identifier: ActiveResource
focal_class.modifiers: @Autowired public
focal_class.parameters: (RequestTypes<T> activeQueries, JobsBeingExecuted activeJobs)
focal_class.signature:  ActiveResource(RequestTypes<T> activeQueries, JobsBeingExecuted activeJobs)
focal_class.class_method_signature: ActiveResource.activeRequests(@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type)
focal_class.full_signature: @GET @Produces("application/json") @Path("/requests") public void activeRequests(@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type)
focal_class.identifier: activeRequests
focal_class.modifiers: @GET @Produces("application/json") @Path("/requests") public
focal_class.parameters: (@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type)
focal_class.return: void
focal_class.signature: void activeRequests(@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type)
focal_class.class_method_signature: ActiveResource.allActiveRequests(@Suspended AsyncResponse asyncResponse)
focal_class.full_signature: @GET @Produces("application/json") @Path("/all-requests") public void allActiveRequests(@Suspended AsyncResponse asyncResponse)
focal_class.identifier: allActiveRequests
focal_class.modifiers: @GET @Produces("application/json") @Path("/all-requests") public
focal_class.parameters: (@Suspended AsyncResponse asyncResponse)
focal_class.return: void
focal_class.signature: void allActiveRequests(@Suspended AsyncResponse asyncResponse)
focal_class.class_method_signature: ActiveResource.activeJobs(@Suspended AsyncResponse asyncResponse)
focal_class.full_signature: @GET @Produces("application/json") @Path("/jobs") public void activeJobs(@Suspended AsyncResponse asyncResponse)
focal_class.identifier: activeJobs
focal_class.modifiers: @GET @Produces("application/json") @Path("/jobs") public
focal_class.parameters: (@Suspended AsyncResponse asyncResponse)
focal_class.return: void
focal_class.signature: void activeJobs(@Suspended AsyncResponse asyncResponse)
focal_method.body: @GET
      @Produces("application/json")
      @Path("/requests")
      public void activeRequests(@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type) {
  
          ReactiveSeq.of((type == null ? "default" : type))
                     .map(typeToUse -> activeQueries.getMap()
                                                    .get(typeToUse)
                                                    .toString())
                     .foldFuture(WorkerThreads.ioExecutor.get(),
                      s->s.forEach(Long.MAX_VALUE,result -> asyncResponse.resume(result)));
  
      }
focal_method.class_method_signature: ActiveResource.activeRequests(@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type)
focal_method.full_signature: @GET @Produces("application/json") @Path("/requests") public void activeRequests(@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type)
focal_method.identifier: activeRequests
focal_method.invocations: foldFuture map of toString get getMap get forEach resume
focal_method.modifiers: @GET @Produces("application/json") @Path("/requests") public
focal_method.parameters: (@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type)
focal_method.return: void
focal_method.signature: void activeRequests(@Suspended AsyncResponse asyncResponse, @QueryParam("type") final String type)