@Test public void testGetInput() { }
public static <Message extends PMessage<Message, Field>, Field extends PField> Stream<Message> getInput(@Nonnull PMessageDescriptor<Message, Field> descriptor, @Nonnull ConvertStream in, boolean strict) throws IOException { Serializer serializer = in.format.createSerializer(strict); InputStream is = getInputStream(in); return StreamSupport.stream(new MessageSpliterator<>(is, serializer, descriptor, is), false); }
FormatUtils { public static <Message extends PMessage<Message, Field>, Field extends PField> Stream<Message> getInput(@Nonnull PMessageDescriptor<Message, Field> descriptor, @Nonnull ConvertStream in, boolean strict) throws IOException { Serializer serializer = in.format.createSerializer(strict); InputStream is = getInputStream(in); return StreamSupport.stream(new MessageSpliterator<>(is, serializer, descriptor, is), false); } }
FormatUtils { public static <Message extends PMessage<Message, Field>, Field extends PField> Stream<Message> getInput(@Nonnull PMessageDescriptor<Message, Field> descriptor, @Nonnull ConvertStream in, boolean strict) throws IOException { Serializer serializer = in.format.createSerializer(strict); InputStream is = getInputStream(in); return StreamSupport.stream(new MessageSpliterator<>(is, serializer, descriptor, is), false); }  }
FormatUtils { public static <Message extends PMessage<Message, Field>, Field extends PField> Stream<Message> getInput(@Nonnull PMessageDescriptor<Message, Field> descriptor, @Nonnull ConvertStream in, boolean strict) throws IOException { Serializer serializer = in.format.createSerializer(strict); InputStream is = getInputStream(in); return StreamSupport.stream(new MessageSpliterator<>(is, serializer, descriptor, is), false); }  static void collectIncludes(File dir, Map<String, File> includes); static void collectConfigIncludes(File rc, Map<String, File> includes); static Map<String, File> getIncludeMap(File rc, List<File> includes); static Stream<Message> getInput(@Nonnull PMessageDescriptor<Message, Field> descriptor,
                             @Nonnull ConvertStream in,
                             boolean strict); static MessageReader getServiceInput(ConvertStream in, boolean strict); static Collector<Message, ?, Integer> getOutput(ConvertStream out,
                                             boolean strict); static MessageWriter getServiceOutput(ConvertStream out, boolean strict); }
FormatUtils { public static <Message extends PMessage<Message, Field>, Field extends PField> Stream<Message> getInput(@Nonnull PMessageDescriptor<Message, Field> descriptor, @Nonnull ConvertStream in, boolean strict) throws IOException { Serializer serializer = in.format.createSerializer(strict); InputStream is = getInputStream(in); return StreamSupport.stream(new MessageSpliterator<>(is, serializer, descriptor, is), false); }  static void collectIncludes(File dir, Map<String, File> includes); static void collectConfigIncludes(File rc, Map<String, File> includes); static Map<String, File> getIncludeMap(File rc, List<File> includes); static Stream<Message> getInput(@Nonnull PMessageDescriptor<Message, Field> descriptor,
                             @Nonnull ConvertStream in,
                             boolean strict); static MessageReader getServiceInput(ConvertStream in, boolean strict); static Collector<Message, ?, Integer> getOutput(ConvertStream out,
                                             boolean strict); static MessageWriter getServiceOutput(ConvertStream out, boolean strict);  }