test_class.declarator: resource
test_class.original_string: ManifestResource resource;
test_class.type: ManifestResource
test_class.var_name: resource
test_class.declarator: context
test_class.original_string: ServletContext context;
test_class.type: ServletContext
test_class.var_name: context
test_class.declarator: response
test_class.original_string: MockAsyncResponse<Map<String, String>> response;
test_class.type: MockAsyncResponse<Map<String, String>>
test_class.var_name: response
test_class.declarator: manifest = "Manifest-Version: 1.0\n"
  			+ "Archiver-Version: Plexus Archiver\n" 
  			+ "Created-By: Apache Maven\n"
  			+ "Implementation-Build: 281837\n"
test_class.modifier: private
test_class.original_string: private String manifest = "Manifest-Version: 1.0\n"
  			+ "Archiver-Version: Plexus Archiver\n" 
  			+ "Created-By: Apache Maven\n"
  			+ "Implementation-Build: 281837\n";
test_class.type: String
test_class.var_name: manifest
test_class.file: micro-events/src/test/java/com/oath/micro/server/rest/resources/ManifestResourceTest.java
test_class.identifier: ManifestResourceTest
test_case.body: @Test
  	public void testMainfest() {
  		when(context.getResourceAsStream(any(String.class))).thenReturn(
  				new ByteArrayInputStream(manifest
  						.getBytes()));
  		resource.mainfest(response,context);
  		Map<String, String> manifest =response.response() ;
  		assertThat(manifest.get("Implementation-Build"), is("281837"));
  
  	}
test_case.class_method_signature: ManifestResourceTest.testMainfest()
test_case.full_signature: @Test public void testMainfest()
test_case.identifier: testMainfest
test_case.invocations: thenReturn when getResourceAsStream any getBytes mainfest response assertThat get is
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testMainfest()
focal_class.declarator: logger = LoggerFactory.getLogger(this.getClass())
focal_class.modifier: private final
focal_class.original_string: private final Logger logger = LoggerFactory.getLogger(this.getClass());
focal_class.type: Logger
focal_class.var_name: logger
focal_class.file: micro-events/src/main/java/com/oath/micro/server/rest/resources/ManifestResource.java
focal_class.identifier: ManifestResource
focal_class.interfaces: implements CommonRestResource, SingletonRestResource
focal_class.class_method_signature: ManifestResource.mainfest(@Suspended AsyncResponse asyncResponse, @Context ServletContext context)
focal_class.full_signature: @GET @Produces("application/json") public void mainfest(@Suspended AsyncResponse asyncResponse, @Context ServletContext context)
focal_class.identifier: mainfest
focal_class.modifiers: @GET @Produces("application/json") public
focal_class.parameters: (@Suspended AsyncResponse asyncResponse, @Context ServletContext context)
focal_class.return: void
focal_class.signature: void mainfest(@Suspended AsyncResponse asyncResponse, @Context ServletContext context)
focal_class.class_method_signature: ManifestResource.getManifest(final InputStream input)
focal_class.full_signature: public Map<String, String> getManifest(final InputStream input)
focal_class.identifier: getManifest
focal_class.modifiers: public
focal_class.parameters: (final InputStream input)
focal_class.return: Map<String, String>
focal_class.signature: Map<String, String> getManifest(final InputStream input)
focal_method.body: @GET
  	@Produces("application/json")
  	public void mainfest(@Suspended AsyncResponse asyncResponse, @Context ServletContext context) {
  
          ReactiveSeq.of("/META-INF/MANIFEST.MF")
                     .map(url -> context.getResourceAsStream(url))
                     .map(this::getManifest)
                     .foldFuture(WorkerThreads.ioExecutor.get(),
                                 s -> s.forEach(Long.MAX_VALUE, result -> asyncResponse.resume(result)));
  	}
focal_method.class_method_signature: ManifestResource.mainfest(@Suspended AsyncResponse asyncResponse, @Context ServletContext context)
focal_method.full_signature: @GET @Produces("application/json") public void mainfest(@Suspended AsyncResponse asyncResponse, @Context ServletContext context)
focal_method.identifier: mainfest
focal_method.invocations: foldFuture map map of getResourceAsStream get forEach resume
focal_method.modifiers: @GET @Produces("application/json") public
focal_method.parameters: (@Suspended AsyncResponse asyncResponse, @Context ServletContext context)
focal_method.return: void
focal_method.signature: void mainfest(@Suspended AsyncResponse asyncResponse, @Context ServletContext context)