Error Observable

Rocket.throwErrorFunction
throwError(error, T = Any)

Creation operator for the ErrorObservable that emits no items to the Actor and immediately sends an error notification.

Arguments

  • error: the particular Error to pass to the error notification.
  • T: type of output data source, optional, Any is the default

Examples

using Rocket

source = throwError("Error!")
subscribe!(source, logger())
;

# output

[LogActor] Error: Error!

See also: ErrorObservable, subscribe!

source