L1:/* L2: [Test Mail] L3:*/ L4:subject: [FESS] Test Mail: /*pmb.hostname:orElse('Unknown')*/ L5:>>> L6:This is a test mail from /*pmb.hostname:orElse('Unknown')*/...

storeQueryId(final String queryId, final List<Map<String, Object>> documentItems) { L173: LaRequestUtil.getOptionalRequest().map(req -> req.getSession(false)).ifPresent(session -> { L174: final FessConfig fessConfig = ComponentUtil.getFessConfig(); L175: L176: final List<String> docIdList = new ArrayList<>(); L177: for (final Map<String, Object> map : documentItems) { L178: final Object docId = map.get(fessConfig.getIndexFieldDocId()); L179: ...

e; L23: L24:/** L25: * An iterator that transforms a backing list iterator; for internal use. This avoids the object L26: * overhead of constructing a {@link Function} for internal methods. L27: * L28: * @author Louis Wasserman L29: */ L30:@GwtCompatible L31:@ElementTypesAreNonnullByDefault L32:abstract class TransformedListIterator<F extends @Nullable Object, T extends @Nullable Object> L33: extends TransformedIterator<F, T> implements ListIterator<T> { L34: TransformedListIterator(ListIterator<?...

e; L23: L24:/** L25: * An iterator that transforms a backing list iterator; for internal use. This avoids the object L26: * overhead of constructing a {@link Function} for internal methods. L27: * L28: * @author Louis Wasserman L29: */ L30:@GwtCompatible L31:@ElementTypesAreNonnullByDefault L32:abstract class TransformedListIterator<F extends @Nullable Object, T extends @Nullable Object> L33: extends TransformedIterator<F, T> implements ListIterator<T> { L34: TransformedListIterator(ListIterator<?...

.checker.nullness.qual.Nullable; L23: L24:/** L25: * Abstract implementation of {@link InvocationHandler} that handles {@link Object#equals}, {@link L26: * Object#hashCode} and {@link Object#toString}. For example: L27: * L28: * <pre> L29: * class Unsupported extends AbstractInvocationHandler { L30: * protected Object handleInvocation(Object proxy, Method method, Object[] args) { L31: * throw new UnsupportedOperationException(); L32: * } L33: * } L34: * L35: * CharSequence unsupported = ...

Source L78: // ====== L79: @Override L80: public Map<String, Object> toSource() { L81: Map<String, Object> sourceMap = new HashMap<>(); L82: if (boostExpr != null) { L83: addFieldToSource(sourceMap, "boostExpr", boostExpr); L84: } L85: if (createdBy != null) { L86: addFieldToSource(sourceMap,...

Source L78: // ====== L79: @Override L80: public Map<String, Object> toSource() { L81: Map<String, Object> sourceMap = new HashMap<>(); L82: if (createdBy != null) { L83: addFieldToSource(sourceMap, "createdBy", createdBy); L84: } L85: if (createdTime != null) { L86: addFieldToSource(sourceMap,...

some platforms can have large buffers that mean writes do not block when L55: // required. These socket factories explicitly set the buffer sizes on sockets created. L56: server = MockWebServer() L57: server.serverSocketFactory = L58: object : DelegatingServerSocketFactory(getDefault()) { L59: @Throws(SocketException::class) L60: override fun configureServerSocket(serverSocket: ServerSocket): ServerSocket { L61: serverSocket.setReceiveBufferSize(SOCKET_BUFFER_SIZE)...

this registry belongs to. */ L67: @Weak private final EventBus bus; L68: L69: SubscriberRegistry(EventBus bus) { L70: this.bus = checkNotNull(bus); L71: } L72: L73: /** Registers all subscriber methods on the given listener object. */ L74: void register(Object listener) { L75: Multimap<Class<?>, Subscriber> listenerMethods = findAllSubscribers(listener); L76: L77: for (Entry<Class<?>, Collection<Subscriber>> entry : listenerMethods.asMap().entrySet()) { L78: Class<?> eventType...

size; i++) { L919: queue[i] = null; L920: } L921: size = 0; L922: } L923: L924: @Override L925: @J2ktIncompatible // Incompatible return type change. Use inherited (unoptimized) implementation L926: public Object[] toArray() { L927: Object[] copyTo = new Object[size]; L928: arraycopy(queue, 0, copyTo, 0, size); L929: return copyTo; L930: } L931: L932: /** L933: * Returns the comparator used to order the elements in this queue. Obeys the general contract of L934: * {@link...