Skip to content

Instantly share code, notes, and snippets.

@joshgarnett
Created September 19, 2017 14:55
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save joshgarnett/cb104904a552136d2f5731f5cfc41a45 to your computer and use it in GitHub Desktop.
Save joshgarnett/cb104904a552136d2f5731f5cfc41a45 to your computer and use it in GitHub Desktop.
Adding support for piping task result to actor as a single message
public class TaskResult<T> {
public bool IsFailed { get; }
public T Result { get; }
public Exception Exception { get; }
public TaskResult(bool isFailed, T result, Exception ex) {
IsFailed = isFailed;
Result = result;
Exception = ex;
}
public static TaskResult<T> Success(T result) {
return new TaskResult<T>(false, result, null);
}
public static TaskResult<T> Failure(Exception ex) {
return new TaskResult<T>(true, default(T), ex);
}
}
public static class TaskExtensions {
public static void PipeResultTo<T>(this Task<object> taskToPipe, ICanTell recipient) {
taskToPipe.ContinueWith(tresult => {
TaskResult<T> message;
if (tresult.IsCanceled || tresult.IsFaulted) {
message = TaskResult<T>.Failure(tresult.Exception);
}
else {
if (tresult.Result is T) {
message = TaskResult<T>.Success((T) tresult.Result);
}
else {
message = TaskResult<T>.Failure(new Exception("Invalid type returned: " + tresult.GetType()));
}
}
recipient.Tell(message, ActorRefs.NoSender);
}, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment