Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 835 for streams (0.06 sec)

  1. guava/src/com/google/common/collect/AbstractBiMap.java

        @J2ktIncompatible
        private void writeObject(ObjectOutputStream stream) throws IOException {
          stream.defaultWriteObject();
          stream.writeObject(inverse());
        }
    
        @GwtIncompatible // java.io.ObjectInputStream
        @J2ktIncompatible
        @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Aug 24 01:40:03 UTC 2023
    - 14.6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/web/api/FessApiAction.java

     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.api;
    
    import java.util.Locale;
    import java.util.stream.Collectors;
    
    import org.codelibs.fess.app.service.AccessTokenService;
    import org.codelibs.fess.app.web.api.ApiResult.ApiErrorResponse;
    import org.codelibs.fess.app.web.api.ApiResult.Status;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. cmd/bitrot-streaming.go

    	"io"
    	"sync"
    
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/ringbuffer"
    )
    
    // Calculates bitrot in chunks and writes the hash into the stream.
    type streamingBitrotWriter struct {
    	iow          io.WriteCloser
    	closeWithErr func(err error)
    	h            hash.Hash
    	shardSize    int64
    	canClose     *sync.WaitGroup
    	byteBuf      []byte
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/KeyMatchHelper.java

            getAvailableKeyMatchList().stream().forEach(keyMatch -> {
                try {
                    final BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
                    if (logger.isDebugEnabled()) {
                        logger.debug("Loading KeyMatch Query: {}, Size: {}", keyMatch.getQuery(), keyMatch.getMaxSize());
                    }
                    getDocumentList(keyMatch).stream().map(doc -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/api/admin/dict/mapping/ApiAdminDictMappingAction.java

    import static org.codelibs.fess.app.web.admin.dict.mapping.AdminDictMappingAction.createCharMappingItem;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.CharMappingPager;
    import org.codelibs.fess.app.service.CharMappingService;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/api/admin/dict/stemmeroverride/ApiAdminDictStemmeroverrideAction.java

    import static org.codelibs.fess.app.web.admin.dict.stemmeroverride.AdminDictStemmeroverrideAction.createStemmerOverrideItem;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.StemmerOverridePager;
    import org.codelibs.fess.app.service.StemmerOverrideService;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/entity/FacetQueryView.java

        @PostConstruct
        public void init() {
            final String filetypeField = ComponentUtil.getFessConfig().getIndexFieldFiletype();
            final Collection<String> values = queryMap.values();
            if (values.stream().anyMatch(s -> s.startsWith(filetypeField))) {
                final ResourceBundle resources = ResourceBundle.getBundle("fess_label", Locale.ENGLISH);
                final String[] fileTypes = ComponentUtil.getFileTypeHelper().getTypes();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbPipeHandleInternal.java

         */
        byte[] getSessionKey () throws CIFSException;
    
    
        /**
         * 
         * @return this pipe's input stream
         * @throws SmbException
         */
        @Override
        SmbPipeInputStream getInput () throws CIFSException;
    
    
        /**
         * 
         * @return this pipe's output stream
         * @throws SmbException
         * @throws
         */
        @Override
        SmbPipeOutputStream getOutput () throws CIFSException;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.5K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/primitives/ImmutableIntArrayTest.java

        assertThat(count.get()).isEqualTo(4);
      }
    
      public void testStream() {
        ImmutableIntArray.of().stream().forEach(i -> fail());
        ImmutableIntArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
        assertThat(ImmutableIntArray.of(0, 1, 3).stream().toArray()).isEqualTo(new int[] {0, 1, 3});
      }
    
      public void testSubArray() {
        ImmutableIntArray iia0 = ImmutableIntArray.of();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/primitives/ImmutableDoubleArrayTest.java

        assertThat(count.get()).isEqualTo(4);
      }
    
      public void testStream() {
        ImmutableDoubleArray.of().stream().forEach(i -> fail());
        ImmutableDoubleArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
        assertThat(ImmutableDoubleArray.of(0, 1, 3).stream().toArray())
            .isEqualTo(new double[] {0, 1, 3});
      }
    
      public void testSubArray() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top