MCPcopy Create free account
hub / github.com/ReactiveX/RxGo / Just

Function Just

factory.go:234–240  ·  view source on GitHub ↗

Just creates an Observable with the provided items.

(items ...interface{})

Source from the content-addressed store, hash-verified

232
233// Just creates an Observable with the provided items.
234func Just(items ...interface{}) func(opts ...Option) Observable {
235 return func(opts ...Option) Observable {
236 return &ObservableImpl{
237 iterable: newJustIterable(items...)(opts...),
238 }
239 }
240}
241
242// JustItem creates a single from one item.
243func JustItem(item interface{}, opts ...Option) Single {

Calls 1

newJustIterableFunction · 0.85

Tested by 15

TestLeakFunction · 0.68
Test_Single_Get_ItemFunction · 0.68
Test_Single_Get_ErrorFunction · 0.68
Test_JustFunction · 0.68
Test_Just_ChannelFunction · 0.68
Test_Just_SimpleCapacityFunction · 0.68

Used in the wild real call sites across dependent graphs

searching dependent graphs…