//
// ========================================================================
// Copyright (c) 1995-2020 Mort Bay Consulting Pty Ltd and others.
//
// This program and the accompanying materials are made available under
// the terms of the Eclipse Public License 2.0 which is available at
// https://www.eclipse.org/legal/epl-2.0
//
// This Source Code may also be made available under the following
// Secondary Licenses when the conditions for such availability set
// forth in the Eclipse Public License, v. 2.0 are satisfied:
// the Apache License v2.0 which is available at
// https://www.apache.org/licenses/LICENSE-2.0
//
// SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
// ========================================================================
//

package org.eclipse.jetty.util;

import java.util.Iterator;
import java.util.ServiceConfigurationError;
import java.util.ServiceLoader;
import java.util.Spliterator;
import java.util.function.Consumer;

class ServiceLoaderSpliterator<T> implements Spliterator<ServiceLoader.Provider<T>>
{
    private final Iterator<T> iterator;

    public ServiceLoaderSpliterator(ServiceLoader<T> serviceLoader)
    {
        iterator = serviceLoader.iterator();
    }

    @Override
    public boolean tryAdvance(Consumer<? super ServiceLoader.Provider<T>> action)
    {
        ServiceProvider<T> next;
        try
        {
            if (!iterator.hasNext())
                return false;
            next = new ServiceProvider<>(iterator.next());
        }
        catch (Throwable t)
        {
            next = new ServiceProvider<>(t);
        }

        action.accept(next);
        return true;
    }

    @Override
    public Spliterator<ServiceLoader.Provider<T>> trySplit()
    {
        return null;
    }

    @Override
    public long estimateSize()
    {
        return Long.MAX_VALUE;
    }

    @Override
    public int characteristics()
    {
        return Spliterator.ORDERED;
    }

    
An implementation of the Provider which contains either an instance of the service or an error to be thrown when someone calls get().
Type parameters:
  • <T> – the service type.
/** * An implementation of the {@link ServiceLoader.Provider} which contains either an instance of the service or * an error to be thrown when someone calls {@link #get()}. * @param <T> the service type. */
private static class ServiceProvider<T> implements ServiceLoader.Provider<T> { private final T service; private final Throwable error; public ServiceProvider(T service) { this.service = service; this.error = null; } public ServiceProvider(Throwable error) { this.service = null; this.error = error; } @Override @SuppressWarnings("unchecked") public Class<? extends T> type() { return (Class<? extends T>)get().getClass(); } @Override public T get() { if (service == null) throw new ServiceConfigurationError("", error); return service; } } }