operation queue will remove an operation when the operation fires a

canceled event. [#29]

src/operations/Operation.as

@@ -1,6 +1,5 @@
 package operations
 {
-	import flash.events.Event;
 	import flash.events.EventDispatcher;
 	import flash.utils.getQualifiedClassName;
 
@@ -11,6 +10,11 @@ package operations
 	 */
 	[Event(name="canceled", type="operations.OperationEvent")]
 
+	/**
+	 * Dispatched when the execution of an operation has been queued.
+	 */
+	[Event(name="queued", type="operations.OperationEvent")]
+
 	/**
 	 * Dispatched after the execution of an operation has started.
 	 */
@@ -200,6 +204,13 @@ package operations
 			}
 		}
 
+		private function fireQueued():void
+		{
+			if (hasEventListener(OperationEvent.QUEUED)) {
+				dispatchEvent( new OperationEvent(OperationEvent.QUEUED) );
+			}
+		}
+
 		private function fireAfterExecute():void
 		{
 			if (hasEventListener(OperationEvent.AFTER_EXECUTE)) {
@@ -271,14 +282,19 @@ package operations
 		 * canceled. If the operation has finished its errors, result data, and progress will
 		 * be reset.
 		 */
-		final public function reset():void
+		final public function queue():void
 		{
 			if (isExecuting) {
-				cancel();
+				cancelRequest();
 			}
+
 			progress.complete = 0;
 			_hasErrored = false;
-			changeState(QUEUED);
+
+			if (!isQueued) {
+				changeState(QUEUED);
+				fireQueued();
+			}
 		}
 
 		/**

src/operations/OperationEvent.as

@@ -16,6 +16,11 @@ package operations
 		 */
 		public static const CANCELED:String = "canceled";
 
+		/**
+		 * The event type for when an operation is queued.
+		 */
+		public static const QUEUED:String = "queued";
+
 		/**
 		 * The event type before an operation is executed.
 		 */

src/operations/OperationQueue.as

@@ -1,5 +1,6 @@
 package operations
 {
+	import flash.events.Event;
 	import flash.events.EventDispatcher;
 
 	import mx.collections.ArrayList;
@@ -55,11 +56,12 @@ package operations
 		public function queue(operation:Operation):void
 		{
 			remove(operation);
-			operation.reset();
+			operation.queue();
 			items.addItem(operation);
 			progress.total += operation.progress.total;
-
 			executeAvailable();
+
+			operation.addEventListener(OperationEvent.CANCELED, handleOperationCanceled);
 		}
 
 		/**
@@ -71,6 +73,8 @@ package operations
 		public function remove(operation:Operation):void
 		{
 			if (_items.removeItem(operation)) {
+				operation.removeEventListener(OperationEvent.CANCELED, handleOperationCanceled);
+
 				if (operation.isFinished) {
 					progress.complete -= operation.progress.complete;
 				}
@@ -109,7 +113,7 @@ package operations
 				_isRunning = false;
 
 				while (executing.length > 0) {
-					(executing.getItemAt(0) as Operation).reset();
+					(executing.getItemAt(0) as Operation).queue();
 				}
 			}
 		}
@@ -132,6 +136,11 @@ package operations
 			operation.execute();
 		}
 
+		private function handleOperationCanceled(event:OperationEvent):void
+		{
+			remove(event.operation);
+		}
+
 		private function handleOperationProgress(event:ProgressOperationEvent):void
 		{