test_class.declarator: service
test_class.original_string: RegistryActionFunction service;
test_class.type: RegistryActionFunction
test_class.var_name: service
test_class.file: docker-actions/src/test/java/fr/xebia/ldi/RegistryActionFunctionTest.java
test_class.identifier: RegistryActionFunctionTest
test_case.body: @Test
      void tryStreamFileSubjectsShouldLoadExistingFile() throws IOException {
          Try<FileInputStream> triedInputStream = service.tryStreamFileSubjects();
  
          assertTrue(triedInputStream.isSuccess());
  
          ByteBuffer buffer = ByteBuffer.wrap(new byte[64]);
          triedInputStream.getUnchecked().getChannel().read(buffer);
          assertEquals(byteToUTF8(buffer).split("\n")[0], "---");
          assertEquals(byteToUTF8(buffer).split("\n")[1], "schemas:");
      }
test_case.class_method_signature: RegistryActionFunctionTest.tryStreamFileSubjectsShouldLoadExistingFile()
test_case.full_signature: @Test void tryStreamFileSubjectsShouldLoadExistingFile()
test_case.identifier: tryStreamFileSubjectsShouldLoadExistingFile
test_case.invocations: tryStreamFileSubjects assertTrue isSuccess wrap read getChannel getUnchecked assertEquals split byteToUTF8 assertEquals split byteToUTF8
test_case.modifiers: @Test
test_case.parameters: ()
test_case.return: void
test_case.signature: void tryStreamFileSubjectsShouldLoadExistingFile()
focal_class.declarator: yaml
focal_class.modifier: private
focal_class.original_string: private Yaml yaml;
focal_class.type: Yaml
focal_class.var_name: yaml
focal_class.declarator: config
focal_class.modifier: private
focal_class.original_string: private Config config;
focal_class.type: Config
focal_class.var_name: config
focal_class.declarator: client
focal_class.modifier: private
focal_class.original_string: private SchemaRegistryClient client;
focal_class.type: SchemaRegistryClient
focal_class.var_name: client
focal_class.declarator: logger = LoggerFactory.getLogger(RegistryActionFunction.class)
focal_class.modifier: private
focal_class.original_string: private Logger logger = LoggerFactory.getLogger(RegistryActionFunction.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.file: docker-actions/src/main/java/fr/xebia/ldi/RegistryActionFunction.java
focal_class.identifier: RegistryActionFunction
focal_class.class_method_signature: RegistryActionFunction.RegistryActionFunction(Config config)
focal_class.full_signature: public  RegistryActionFunction(Config config)
focal_class.identifier: RegistryActionFunction
focal_class.modifiers: public
focal_class.parameters: (Config config)
focal_class.signature:  RegistryActionFunction(Config config)
focal_class.class_method_signature: RegistryActionFunction.RegistryActionFunction(Config config, SchemaRegistryClient schemaRegistryClient)
focal_class.full_signature: public  RegistryActionFunction(Config config, SchemaRegistryClient schemaRegistryClient)
focal_class.identifier: RegistryActionFunction
focal_class.modifiers: public
focal_class.parameters: (Config config, SchemaRegistryClient schemaRegistryClient)
focal_class.signature:  RegistryActionFunction(Config config, SchemaRegistryClient schemaRegistryClient)
focal_class.class_method_signature: RegistryActionFunction.getYaml()
focal_class.full_signature: public Yaml getYaml()
focal_class.identifier: getYaml
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Yaml
focal_class.signature: Yaml getYaml()
focal_class.class_method_signature: RegistryActionFunction.getClient()
focal_class.full_signature: public SchemaRegistryClient getClient()
focal_class.identifier: getClient
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: SchemaRegistryClient
focal_class.signature: SchemaRegistryClient getClient()
focal_class.class_method_signature: RegistryActionFunction.getParser()
focal_class.full_signature: public Schema.Parser getParser()
focal_class.identifier: getParser
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Schema.Parser
focal_class.signature: Schema.Parser getParser()
focal_class.class_method_signature: RegistryActionFunction.setYaml()
focal_class.full_signature: private void setYaml()
focal_class.identifier: setYaml
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void setYaml()
focal_class.class_method_signature: RegistryActionFunction.setClient()
focal_class.full_signature: private void setClient()
focal_class.identifier: setClient
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void setClient()
focal_class.class_method_signature: RegistryActionFunction.tryStreamFileSubjects()
focal_class.full_signature: public Try<FileInputStream> tryStreamFileSubjects()
focal_class.identifier: tryStreamFileSubjects
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Try<FileInputStream>
focal_class.signature: Try<FileInputStream> tryStreamFileSubjects()
focal_class.class_method_signature: RegistryActionFunction.parseYaml(FileInputStream input)
focal_class.full_signature: public Try<List<SchemaList.SubjectEntry>> parseYaml(FileInputStream input)
focal_class.identifier: parseYaml
focal_class.modifiers: public
focal_class.parameters: (FileInputStream input)
focal_class.return: Try<List<SchemaList.SubjectEntry>>
focal_class.signature: Try<List<SchemaList.SubjectEntry>> parseYaml(FileInputStream input)
focal_class.class_method_signature: RegistryActionFunction.mapSubjectToFile(List<SchemaList.SubjectEntry> subjects)
focal_class.full_signature: public List<KeyValuePair<String, File>> mapSubjectToFile(List<SchemaList.SubjectEntry> subjects)
focal_class.identifier: mapSubjectToFile
focal_class.modifiers: public
focal_class.parameters: (List<SchemaList.SubjectEntry> subjects)
focal_class.return: List<KeyValuePair<String, File>>
focal_class.signature: List<KeyValuePair<String, File>> mapSubjectToFile(List<SchemaList.SubjectEntry> subjects)
focal_class.class_method_signature: RegistryActionFunction.parseOne(KeyValuePair<String, File> subjectFilePair)
focal_class.full_signature: public Try<KeyValuePair<String, Schema>> parseOne(KeyValuePair<String, File> subjectFilePair)
focal_class.identifier: parseOne
focal_class.modifiers: public
focal_class.parameters: (KeyValuePair<String, File> subjectFilePair)
focal_class.return: Try<KeyValuePair<String, Schema>>
focal_class.signature: Try<KeyValuePair<String, Schema>> parseOne(KeyValuePair<String, File> subjectFilePair)
focal_class.class_method_signature: RegistryActionFunction.parseAll(List<KeyValuePair<String, File>> subjectFilePairs)
focal_class.full_signature: public Try<List<KeyValuePair<String, Schema>>> parseAll(List<KeyValuePair<String, File>> subjectFilePairs)
focal_class.identifier: parseAll
focal_class.modifiers: public
focal_class.parameters: (List<KeyValuePair<String, File>> subjectFilePairs)
focal_class.return: Try<List<KeyValuePair<String, Schema>>>
focal_class.signature: Try<List<KeyValuePair<String, Schema>>> parseAll(List<KeyValuePair<String, File>> subjectFilePairs)
focal_class.class_method_signature: RegistryActionFunction.testOne(KeyValuePair<String, Schema> subjectSchemaPair)
focal_class.full_signature: public Try<KeyValuePair<String, Boolean>> testOne(KeyValuePair<String, Schema> subjectSchemaPair)
focal_class.identifier: testOne
focal_class.modifiers: public
focal_class.parameters: (KeyValuePair<String, Schema> subjectSchemaPair)
focal_class.return: Try<KeyValuePair<String, Boolean>>
focal_class.signature: Try<KeyValuePair<String, Boolean>> testOne(KeyValuePair<String, Schema> subjectSchemaPair)
focal_class.class_method_signature: RegistryActionFunction.testAll(List<KeyValuePair<String, Schema>> subjectSchemaPairs)
focal_class.full_signature: public Try<List<KeyValuePair<String, Boolean>>> testAll(List<KeyValuePair<String, Schema>> subjectSchemaPairs)
focal_class.identifier: testAll
focal_class.modifiers: public
focal_class.parameters: (List<KeyValuePair<String, Schema>> subjectSchemaPairs)
focal_class.return: Try<List<KeyValuePair<String, Boolean>>>
focal_class.signature: Try<List<KeyValuePair<String, Boolean>>> testAll(List<KeyValuePair<String, Schema>> subjectSchemaPairs)
focal_class.class_method_signature: RegistryActionFunction.travers(List<Try<T>> tries)
focal_class.full_signature: public Try<Stream<T>> travers(List<Try<T>> tries)
focal_class.identifier: travers
focal_class.modifiers: public
focal_class.parameters: (List<Try<T>> tries)
focal_class.return: Try<Stream<T>>
focal_class.signature: Try<Stream<T>> travers(List<Try<T>> tries)
focal_class.class_method_signature: RegistryActionFunction.not(Predicate<R> predicate)
focal_class.full_signature: public static Predicate<R> not(Predicate<R> predicate)
focal_class.identifier: not
focal_class.modifiers: public static
focal_class.parameters: (Predicate<R> predicate)
focal_class.return: Predicate<R>
focal_class.signature: Predicate<R> not(Predicate<R> predicate)
focal_class.class_method_signature: RegistryActionFunction.extractionFailure()
focal_class.full_signature: private static Try<T> extractionFailure()
focal_class.identifier: extractionFailure
focal_class.modifiers: private static
focal_class.parameters: ()
focal_class.return: Try<T>
focal_class.signature: Try<T> extractionFailure()
focal_method.body: public Try<FileInputStream> tryStreamFileSubjects() {
          File file = new File(this.config.getString("avro.subjects.yaml"));
  
          return Try
                  .ofFailable(() ->  new FileInputStream(file))
                  .onFailure((t) -> logger.error("Fail to load the yaml file, it may not exist.", t));
      }
focal_method.class_method_signature: RegistryActionFunction.tryStreamFileSubjects()
focal_method.full_signature: public Try<FileInputStream> tryStreamFileSubjects()
focal_method.identifier: tryStreamFileSubjects
focal_method.invocations: getString onFailure ofFailable error
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: Try<FileInputStream>
focal_method.signature: Try<FileInputStream> tryStreamFileSubjects()