op_schedule_on.go

package mono

import (
	"context"

	"github.com/jjeffcaii/reactor-go"
	"github.com/jjeffcaii/reactor-go/scheduler"
)

type monoScheduleOn struct {
	source reactor.RawPublisher
	sc     scheduler.Scheduler
}

func (m monoScheduleOn) Parent() reactor.RawPublisher {
	return m.source
}

func (m monoScheduleOn) SubscribeWith(ctx context.Context, s reactor.Subscriber) {
	if err := m.sc.Worker().Do(func() {
		m.source.SubscribeWith(ctx, s)
	}); err != nil {
		panic(err)
	}
}

func newMonoScheduleOn(s reactor.RawPublisher, sc scheduler.Scheduler) monoScheduleOn {
	return monoScheduleOn{
		source: s,
		sc:     sc,
	}
}