Function Defer

factory.go:172–176

Defer does not create the Observable until the observer subscribes, and creates a fresh Observable for each observer.

(f []Producer, opts ...Option)

// Defer does not create the Observable until the observer subscribes,
// and creates a fresh Observable for each observer.
func Defer(f []Producer, opts ...Option) Observable {
	return &ObservableImpl{
		iterable: newDeferIterable(f, opts...),
	}
}

// Empty creates an Observable with no item and terminate immediately.
func Empty() Observable {