Utilities

In addition to concurrency, error handling and resiliency features, Ox includes some utility methods, which make writing direct-style Scala code more convenient. When possible, these are inline methods taking inline parameters, hence incurring no runtime overhead.

Top-level methods:

• uninterruptible { ... } evaluates the given code block making sure it can’t be interrupted

• sleep(scala.concurrent.Duration) blocks the current thread/fork for the given duration; same as Thread.sleep, but using’s Scala’s Duration

Extension functions on arbitrary expressions:

• .discard extension method evaluates the given code block and discards its result, avoiding “discarded non-unit value” warnings

• .pipe(f) applies f to the value of the expression and returns the result; useful for chaining operations

• .tap(f) applies f to the value of the expression and returns the original value; useful for side-effecting operations

• .tapException(Throwable => Unit) and .tapNonFatalException(Throwable => Unit) allow running the provided side-effecting callback when the expression throws an exception

Extension functions on scala.concurrent.Future[T]:

• .get(): T blocks the current thread/fork until the future completes; returns the successful value of the future, or throws the exception, with which it failed