Executing long-running actions inside an actor’s Receive method

[senzacionale]

I am reading this howto
https://petabridge.com/blog/top-7-akkadotnet-stumbling-blocks/

But this is not valid scenario any more

public class FooActor : ReceiveActor,
						IWithUnboundedStash{

	private Task _runningTask;
	private CancellationTokenSource _cancel;

	public IStash Stash {get; set;}

	public FooActor(){
		_cancel = new CancellationTokenSource();
		Ready();
	}

	private void Ready(){
		Receive<Start>(s => {
			var self = Self; // closure
			_runningTask = Task.Run(() => {
				// ... work
			}, _cancel.Token).ContinueWith(x =>
			{
				if(x.IsCancelled || x.IsFaulted)
					return new Failed();
				return new Finished();
			}, TaskContinuationOptions.ExecuteSynchronously)
			.PipeTo(self);

			// switch behavior
			Become(Working);
		})
	}

	private void Working(){
		Receive<Cancel>(cancel => {
			_cancel.Cancel(); // cancel work
			BecomeReady();
		});
		Receive<Failed>(f => BecomeReady());
		Receive<Finished>(f => BecomeReady());
		ReceiveAny(o => Stash.Stash());
	}

	private void BecomeReady(){
		_cancel = new CancellationTokenSource();
		Stash.UnstashAll();
		Become(Ready);
	}
}

Failed and Finished does not exist any more

if(x.IsCancelled || x.IsFaulted)
					return new Failed();
				return new Finished();

Can you provide update maybe?

[ismaelhamed]

@senzacionale Failed and Finished would most likely be part of the FooActor's protocol in that example. You can go ahead and add those classes yourself, it'll work.