Single Observable

Rocket.ofFunction
of(x)

Creation operator for the SingleObservable that emits a single value x and then completes.

Arguments

  • x: value to be emmited before completion

Examples

using Rocket

source = of(1)
subscribe!(source, logger())
;

# output

[LogActor] Data: 1
[LogActor] Completed

See also: SingleObservable, subscribe!, logger

source