Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 200 for inferred (0.04 seconds)

  1. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

        @Test
        public void test_promiseChaining_returnsSamePromise() throws Exception {
            final Deferred<SuggestResponse> deferred = new Deferred<>();
    
            Deferred<SuggestResponse>.Promise promise1 = deferred.promise();
            Deferred<SuggestResponse>.Promise promise2 = promise1.then(response -> {});
            Deferred<SuggestResponse>.Promise promise3 = promise2.error(error -> {});
    
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 21.1K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/suggest/request/Request.java

         */
        public Deferred<T>.Promise execute(final Client client) {
            final String error = getValidationError();
            if (!Strings.isNullOrEmpty(error)) {
                throw new IllegalArgumentException(error);
            }
    
            final Deferred<T> deferred = new Deferred<>();
            try {
                processRequest(client, deferred);
            } catch (final Exception e) {
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Nov 23 11:21:40 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  3. src/main/java/jcifs/dcerpc/msrpc/srvsvc.java

                if (this.netname != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(this.netname);
    
                }
                if (this.remark != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(this.remark);
    
                }
                if (this.path != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(this.path);
    
                }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 27K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/suggest/index/operations/ContentIndexingOperations.java

         * @return A Promise that will be resolved with the SuggestIndexResponse
         */
        public Deferred<SuggestIndexResponse>.Promise indexFromQueryLog(final ContentIndexingContext ctx, final QueryLogReader queryLogReader,
                final int docPerReq, final long requestInterval) {
            final Deferred<SuggestIndexResponse> deferred = new Deferred<>();
            threadPool.execute(() -> {
                final long start = System.currentTimeMillis();
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Mar 14 02:35:38 GMT 2026
    - 21.7K bytes
    - Click Count (0)
  5. src/main/java/jcifs/dcerpc/msrpc/netdfs.java

                if (this.path != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(this.path);
    
                }
                if (this.comment != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(this.comment);
    
                }
                if (this.stores != null) {
                    _dst = _dst.deferred;
                    final int _storess = this.num_stores;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/dcerpc/msrpc/srvsvc.java

                if (netname != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(netname);
    
                }
                if (remark != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(remark);
    
                }
                if (path != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(path);
    
                }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 26.3K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb1/dcerpc/ndr/NdrBuffer.java

            nb.index = idx;
            nb.deferred = deferred;
            return nb;
        }
    
        /**
         * Resets the buffer position to the start.
         */
        public void reset() {
            this.index = start;
            length = 0;
            deferred = this;
        }
    
        /**
         * Returns the current index position in the buffer.
         *
         * @return the current index
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/dcerpc/msrpc/netdfs.java

                if (path != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(path);
    
                }
                if (comment != null) {
                    _dst = _dst.deferred;
                    _dst.enc_ndr_string(comment);
    
                }
                if (stores != null) {
                    _dst = _dst.deferred;
                    final int _storess = num_stores;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  9. src/main/java/jcifs/dcerpc/msrpc/lsarpc.java

                    _dst = _dst.deferred;
                    this.root_directory.encode(_dst);
    
                }
                if (this.object_name != null) {
                    _dst = _dst.deferred;
                    this.object_name.encode(_dst);
    
                }
                if (this.security_quality_of_service != null) {
                    _dst = _dst.deferred;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 44.5K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/suggest/request/popularwords/PopularWordsRequest.java

                        deferred.reject(new SuggesterException("Search failure. Failed shards num:" + searchResponse.getFailedShards()));
                    } else {
                        deferred.resolve(createResponse(searchResponse));
                    }
                }
    
                @Override
                public void onFailure(final Exception e) {
                    deferred.reject(e);
                }
            });
        }
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Thu Aug 07 02:41:28 GMT 2025
    - 9.2K bytes
    - Click Count (0)
Back to Top