Skip to content

Commit 6e30a48

Browse files
committed
Make Ack contravariant
1 parent 1172fdc commit 6e30a48

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/scala/model.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ object model {
3838
* Decides when to signal backpressure given the result or error
3939
* of a job
4040
*/
41-
type Ack[A] = Either[Throwable, A] => BackPressure
41+
type Ack[-A] = Either[Throwable, A] => BackPressure
4242

4343
/**
4444
* Never backpressure

0 commit comments

Comments
 (0)