类的使用
io.github.kavahub.file.query.Query

使用Query的程序包

程序包	说明
io.github.kavahub.file.query
io.github.kavahub.file.reader
io.github.kavahub.file.writer

io.github.kavahub.file.query中Query的使用

io.github.kavahub.file.query中Query的子类

修饰符和类型	类	说明
class	QueryDistinct<T>
class	QueryFilter<T>
class	QueryFlatMapConcat<T,R>
class	QueryFlatMapMerge<T,R>
class	QueryFork<T>
class	QueryMap<T,R>
class	QueryOf<T>
class	QueryOfArray<T>
class	QueryOfIterator<T>
class	QueryOnNext<T>
class	QuerySkip<T>
class	QueryTakeWhile<T>

返回Query的io.github.kavahub.file.query中的方法

修饰符和类型	方法	说明
Query<T>	Query.distinct()	Returns a query consisting of the distinct elements (according to Object.equals(Object)) of this query.
Query<T>	Query.filter(Predicate<? super T> p)	Returns an asynchronous query consisting of the elements of this query that match the given predicate.
<R> Query<R>	Query.flatMapConcat(Function<? super T,? extends Query<? extends R>> mapper)	Returns an asynchronous query consisting of the results of replacing each element of this query with the contents of a mapped query produced by applying the provided mapping function to each element.
<R> Query<R>	Query.flatMapMerge(Function<? super T,? extends Query<? extends R>> mapper)
static <U> Query<U>	Query.fork(U[] data)	Returns an asynchronous sequential ordered query whose elements are the specified values in data parameter running on thread pool.
<R> Query<R>	Query.map(Function<? super T,? extends R> mapper)	Returns an asynchronous query consisting of the results of applying the given function to the elements of this query.
static <U> Query<U>	Query.of(Iterator<U> iter)	Returns an asynchronous sequential ordered query whose elements are the specified values in the Iterator parameter.
static <U> Query<U>	Query.of(U data)
static <U> Query<U>	Query.of(U[] data)	Returns an asynchronous sequential ordered query whose elements are the specified values in data parameter.
Query<T>	Query.onNext(BiConsumer<? super T,? super Throwable> action)	Returns a new asynchronous query emitting the same items of this query, additionally performing the provided action on each element as elements are consumed from the resulting query.
Query<T>	Query.skip(int n)	Returns a new asynchronous query consisting of the remaining elements of this query after discarding the first n elements of the query.
Query<T>	Query.takeWhile(Predicate<? super T> predicate)	Returns a query consisting of the longest prefix of elements taken from this query that match the given predicate.

类型变量类型为Query的io.github.kavahub.file.query中的方法参数

修饰符和类型	方法	说明
<R> Query<R>	Query.flatMapConcat(Function<? super T,? extends Query<? extends R>> mapper)	Returns an asynchronous query consisting of the results of replacing each element of this query with the contents of a mapped query produced by applying the provided mapping function to each element.
<R> Query<R>	Query.flatMapMerge(Function<? super T,? extends Query<? extends R>> mapper)

参数类型为Query的io.github.kavahub.file.query中的构造器

构造器	说明
QueryDistinct(Query<T> query)
QueryFilter(Query<T> query, Predicate<? super T> p)
QueryFlatMapConcat(Query<T> upstream, Function<? super T,? extends Query<? extends R>> mapper)
QueryFlatMapMerge(Query<T> query, Function<? super T,? extends Query<? extends R>> mapper)
QueryMap(Query<T> query, Function<? super T,? extends R> mapper)
QueryOnNext(Query<T> query, BiConsumer<? super T,? super Throwable> action)
QuerySkip(Query<T> query, int skip)
QueryTakeWhile(Query<T> query, Predicate<? super T> p)

类型变量类型为Query的io.github.kavahub.file.query中的构造器参数

构造器	说明
QueryFlatMapConcat(Query<T> upstream, Function<? super T,? extends Query<? extends R>> mapper)
QueryFlatMapMerge(Query<T> query, Function<? super T,? extends Query<? extends R>> mapper)

io.github.kavahub.file.reader中Query的使用

io.github.kavahub.file.reader中Query的子类

修饰符和类型	类	说明
class	FileByteReaderQuery
class	QueryAllBytes
class	QueryLine

返回Query的io.github.kavahub.file.reader中的方法

修饰符和类型	方法	说明
Query<byte[]>	AIOFileReader.allBytes(Path file)
Query<byte[]>	AIOFileReader.allBytes(Path file, int bufferSize)
Query<String>	AIOFileReader.allLines(Path file)
Query<String>	AIOFileReader.allLines(Path file, int bufferSize)
Query<byte[]>	AIOFileReader.bytes(Path file)
Query<byte[]>	AIOFileReader.bytes(Path file, int bufferSize)
Query<String>	AIOFileReader.line(Path file)
Query<String>	AIOFileReader.line(Path file, int bufferSize)
static Query<String>	NIOFileLineReader.read(Path file)

参数类型为Query的io.github.kavahub.file.reader中的构造器

构造器	说明
QueryAllBytes(Query<byte[]> query)
QueryLine(Query<byte[]> query)

io.github.kavahub.file.writer中Query的使用

参数类型为Query的io.github.kavahub.file.writer中的方法

修饰符和类型	方法	说明
CompletableFuture<Integer>	AIOFileWriter.write(Path file, Query<String> lines)
CompletableFuture<Integer>	AIOFileWriter.write(Path file, Query<String> lines, StandardOpenOption... options)