We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
The contract will change such that:
Continue
Cancel
Move Ack in monix.execution and introduce these macro-enabled extensions for Future[Ack]:
Ack
monix.execution
Future[Ack]
def syncOnContinue(callback: => Unit)(implicit s: Scheduler): Self
def syncOnCancelOrFailure(callback: => Unit)(implicit s: Scheduler): Self
def syncMap(f: Ack => Ack)(implicit s: Scheduler): Future[Ack]
def syncFlatMap(f: Ack => Future[Ack])(implicit s: Scheduler): Future[Ack]
def syncTryFlatten(implicit r: UncaughtExceptionReporter): Future[Ack]
The purpose of these is dealing with synchronous execution. These will replace our internal utilities defined in monix.internal.
monix.internal
The text was updated successfully, but these errors were encountered:
Issue #121 - move Ack and introduce Future[Ack] extensions
6c14254
Done.
Sorry, something went wrong.
No branches or pull requests
The contract will change such that:
Continue
andCancel
are considered to be synchronousMove
Ack
inmonix.execution
and introduce these macro-enabled extensions forFuture[Ack]
:def syncOnContinue(callback: => Unit)(implicit s: Scheduler): Self
(macro)def syncOnCancelOrFailure(callback: => Unit)(implicit s: Scheduler): Self
(macro)def syncMap(f: Ack => Ack)(implicit s: Scheduler): Future[Ack]
(macro)def syncFlatMap(f: Ack => Future[Ack])(implicit s: Scheduler): Future[Ack]
(macro)def syncTryFlatten(implicit r: UncaughtExceptionReporter): Future[Ack]
(macro)The purpose of these is dealing with synchronous execution. These will replace our internal utilities defined in
monix.internal
.The text was updated successfully, but these errors were encountered: