oleg-smith

package main

import (
	"bufio"
	"flag"
	"fmt"
	"io"
	"log"
	"net/http"
	"net/url"

oleg-smith

import lombok.SneakyThrows;

import javax.annotation.concurrent.NotThreadSafe;
import java.util.Iterator;
import java.util.concurrent.BlockingQueue;

@NotThreadSafe
public class BlockingQueueIterator<T> implements Iterator<T> {

	private final BlockingQueue<QueueEntry<T>> queue;