connect.go

ch := make(chan rxgo.Item)
go func() {
	ch <- rxgo.Of(1)
	ch <- rxgo.Of(2)
	ch <- rxgo.Of(3)
	close(ch)
}()

source := rxgo.FromChannel(ch, rxgo.WithPublishStrategy())

obs1 := source.Map(func(_ context.Context, i interface{}) (interface{}, error) {
	return i.(int) + 1, nil
}).DoOnNext(func(i interface{}) {
	fmt.Printf("%v\n", i)
})

obs2 := source.Map(func(_ context.Context, i interface{}) (interface{}, error) {
	return i.(int) * 10, nil
}).DoOnNext(func(i interface{}) {
	fmt.Printf("%v\n", i)
})

source.Connect()
<-obs1
<-obs2