Class BasicQueryResult

    • Constructor Detail

      • BasicQueryResult

        public BasicQueryResult()
        If this constructor is used, setPathInfo must be called later. No results will be processed until path info is set.
      • BasicQueryResult

        public BasicQueryResult​(java.util.List<PathInfo> pathInfos)
    • Method Detail

      • getError

        public java.lang.Exception getError()
        Specified by:
        getError in interface QueryResult
      • getPathInfo

        public java.util.List<PathInfo> getPathInfo()
        Description copied from interface: QueryResult
        Information about the paths queried. Corresponds 1-to-1 with the paths passed in when the query was executed.
        Specified by:
        getPathInfo in interface QueryResult
      • setPathInfo

        protected void setPathInfo​(java.util.List<PathInfo> pathInfo)
        Sets the path info and releases the lock on getPathInfos.
      • hasNext

        public boolean hasNext()
        Specified by:
        hasNext in interface java.util.Iterator<ResultDataPoint>
      • onData

        public void onData​(java.util.function.Consumer<DataPoint> consumer,
                           java.util.function.BiConsumer<java.lang.Boolean,​java.lang.Throwable> onComplete)
        Specified by:
        onData in interface QueryResult
      • cancel

        public void cancel()
        Description copied from interface: QueryResult
        Cancels the query. Will call onComplete immediately, and will no longer process values. If takeNext() is blocked, it will throw an interrupted exception.
        Specified by:
        cancel in interface QueryResult
      • finishInternal

        protected void finishInternal​(java.lang.Exception ex)