Completed Observable

Rocket.completedFunction
completed(T = Any)

Creation operator for the CompletedObservable that emits no items to the Actor and immediately sends a complete notification on subscription.

Arguments

  • T: type of output data source, optional, Any is the default

Examples

using Rocket

source = completed(Int)
subscribe!(source, logger())
;

# output

[LogActor] Completed

See also: CompletedObservable, subscribe!, logger

source