diff --git a/src/Flo/Builder.cs b/src/Flo/Builder.cs
index 54f3ac1..31c4a3e 100644
--- a/src/Flo/Builder.cs
+++ b/src/Flo/Builder.cs
@@ -83,7 +83,7 @@ public TBuilder Add(Func<IHandler<TIn, TOut>> handlerFactory)
                 
                 if (handler != null)
                 {
-                    return handler.HandleAsync(input, next, CancellationToken.None);
+                    return handler.HandleAsync(input, next);
                 }
 
                 return next.Invoke(input);
diff --git a/src/Flo/IHandler.cs b/src/Flo/IHandler.cs
index 43a2c1b..1eefe8f 100644
--- a/src/Flo/IHandler.cs
+++ b/src/Flo/IHandler.cs
@@ -6,7 +6,7 @@ namespace Flo
 {
     public interface IHandler<TIn, TOut>
     {
-        Task<TOut> HandleAsync(TIn input, Func<TIn, Task<TOut>> next, CancellationToken token);
+        Task<TOut> HandleAsync(TIn input, Func<TIn, Task<TOut>> next);
     }
     
     public interface IHandler<T> : IHandler<T, T>
diff --git a/test/Flo.Tests/HandlerTests.cs b/test/Flo.Tests/HandlerTests.cs
index fdc9573..5453e41 100644
--- a/test/Flo.Tests/HandlerTests.cs
+++ b/test/Flo.Tests/HandlerTests.cs
@@ -56,7 +56,7 @@ async Task it_can_use_a_custom_service_provider()
 
         class TestHandler : IHandler<TestContext>
         {           
-            public Task<TestContext> HandleAsync(TestContext input, Func<TestContext, Task<TestContext>> next, CancellationToken cancellationToken)
+            public Task<TestContext> HandleAsync(TestContext input, Func<TestContext, Task<TestContext>> next)
             {
                 input.Add(Guid.NewGuid().ToString(), Guid.NewGuid());
                 return next.Invoke(input);
@@ -72,7 +72,7 @@ public LazyHandler(Action callback)
                 _callback = callback;
             }
             
-            public Task<object> HandleAsync(object input, Func<object, Task<object>> next, CancellationToken cancellationToken)
+            public Task<object> HandleAsync(object input, Func<object, Task<object>> next)
             {
                 _callback.Invoke();
                 return next.Invoke(input);
@@ -81,7 +81,7 @@ public Task<object> HandleAsync(object input, Func<object, Task<object>> next, C
 
         class StringLengthCountHandler : IHandler<string, int>
         {
-            public Task<int> HandleAsync(string input, Func<string, Task<int>> next, CancellationToken cancellationToken)
+            public Task<int> HandleAsync(string input, Func<string, Task<int>> next)
             {
                 return Task.FromResult(input.Length);
             }
@@ -98,7 +98,7 @@ public OverridingHandler(string output)
                 _output = output;
             }
             
-            public Task<string> HandleAsync(string input, Func<string, Task<string>> next, CancellationToken cancellationToken)
+            public Task<string> HandleAsync(string input, Func<string, Task<string>> next)
             {
                 return Task.FromResult("Override");
             }