package com.github.davidmoten.rx.internal.operators;

import java.util.Queue;

public interface CloseableQueue<T> extends Queue<T> {

	void close();
	
}

@@ -127,16 +127,199 @@
 e%3CT%3E %7B%0A%0A
+%09/**%0A%09 * %3Cp%3E%0A%09 * Closes the queue (for example frees its resources by clearing its entries%0A%09 * from memory or deleting its files from disk).%0A%09 * %0A%09 * %3Cp%3E%0A%09 * Must be idempotent.%0A%09 */%0A
 %09void cl
@@ -325,12 +325,11 @@
 lose();%0A
-%09
 %0A%7D%0A

add javadoc