RxGo で Observable の購読を途中でキャンセルする方法
Go
ReactiveX
how to
RxGo で Observable の購読をキャンセルするには context.Context を利用します。
parent := context.Background()
ctx, cancel := context.WithCancel(parent)
<-observable.ForEach(func(i interface{}) {
}, func(err error) {
}, func() {
}, rxgo.WithContext(ctx))
// cancel を実行することで購読をキャンセルすることができます
cancel()context.Context の準備
キャンセルすることのできる context.Context を生成しておきます。
parent := context.Background()
ctx, cancel := context.WithCancel(parent)ForEach にオプションとして context.Context を与える
Observable.ForEach は第 4 引数以降にオプションを与えることができます。rxgo.WithContext を利用すれば購読処理に context.Context を与えることができます。
