final class PartiallyAppliedFilter[F[_]] extends AnyVal
- Alphabetic
- By Inheritance
- PartiallyAppliedFilter
- AnyVal
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- Any
- final def ##: Int
- Definition Classes
- Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def collect[T](path: JsonPath, collector: Aux[Token, T], deterministic: Boolean = true, maxMatch: Int = Int.MaxValue, maxNest: Int = Int.MaxValue)(implicit F: Concurrent[F]): Pipe[F, Token, T]
Selects all matching elements in the input stream, and applies the fs2.Collector to it.
Selects all matching elements in the input stream, and applies the fs2.Collector to it.
If
deterministic
is set totrue
(default value), elements are emitted in the order they appeat in the input stream, i.e. first opening tag first. Ifdeterministic
is set tofalse
, built elements are emitted as soon as possible (i.e. when the value is entirely built).The
maxMatch
parameter controls how many matches are to be emitted at most. Further matches won't be emitted if any.The
maxNest
parameter controls the maximum level of match nesting to be emitted. E.g., if you want to emit only the top most matches, set it to0
. - val dummy: Boolean
- def first(path: JsonPath)(implicit F: Concurrent[F]): Pipe[F, Token, Token]
Selects the first match in the input stream.
Selects the first match in the input stream. The tokens of the first matching value are emitted as they are read.
The other matches are gently discarded.
- def getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def raw(path: JsonPath, maxMatch: Int = Int.MaxValue, maxNest: Int = Int.MaxValue)(implicit F: Concurrent[F]): Pipe[F, Token, Stream[F, Token]]
Selects all macthing elements in the input stream.
Selects all macthing elements in the input stream. Each matching element is emitted in a new stream. Matching is performed in a streaming fashion, and events are emitted as early as possible. The match streams are emitted in the same order they are encountered in the input stream, i.e. in the order of the opening tags matching the query.
The
maxMatch
parameter controls how many matches are to be emitted at most. Further matches won't be emitted if any.The
maxNest
parameter controls the maximum level of match nesting to be emitted. E.g., if you want to emit only the top most matches, set it to0
.Warning: make sure you actually consume all the emitted streams otherwise this can lead to memory problems.
- def toString(): String
- Definition Classes
- Any
- def values[T](path: JsonPath, deterministic: Boolean = true, maxMatch: Int = Int.MaxValue, maxNest: Int = Int.MaxValue)(implicit F: Concurrent[F], builder: Builder[T]): Pipe[F, Token, T]
Selects all matching elements in the input stream, and builds an AST.
Selects all matching elements in the input stream, and builds an AST.
If
deterministic
is set totrue
(default value), elements are emitted in the order they appeat in the input stream, i.e. first opening tag first. Ifdeterministic
is set tofalse
, built elements are emitted as soon as possible (i.e. when the value is entirely built).The
maxMatch
parameter controls how many matches are to be emitted at most. Further matches won't be emitted if any.The
maxNest
parameter controls the maximum level of match nesting to be emitted. E.g., if you want to emit only the top most matches, set it to0
.