func NewSubscriber() Subscriber {
	return subscriber.New()
}
jig:template NewSubscriber
jig:needs Subscriber
NewSubscriber creates a new subscriber.
package rx
import (
	"fmt"
	"sync/atomic"
	"github.com/reactivego/scheduler"
	"github.com/reactivego/subscriber"
)
type Subscription = subscriber.Subscription
type Subscriber = subscriber.Subscriber