Open
Description
I would like to add subscribers and unsubscribe something like create a subscription and be able to unsubscribe the specific subscription without breaking the observable completely
ch := make(chan rxgo.Item)
obs := rxgo.FromChannel(ch, rxgo.WithPublishStrategy())
obs.Connect()
newObs := obs.Map(func(ctx context.Context, i interface{}) (interface{}, error) {
return i.(int) * 2, nil
})
dispose := newObs.DoOnNext(func(i interface{}) {
fmt.Println(i)
})
dispose()