start.md

Start Operator

Overview

Create an Observable that emits the return value of a function.

Example

observable := rxgo.Start([]rxgo.Supplier{func(ctx context.Context) rxgo.Item {
	return rxgo.Of(1)
}, func(ctx context.Context) rxgo.Item {
	return rxgo.Of(2)
}})

Output:

1
2

Options

• WithBufferedChannel

• WithContext

• WithObservationStrategy

• WithErrorStrategy

• WithPublishStrategy