RxGo: github.com/ReactiveX/RxGo/subscription Index | Files

package subscription

import "github.com/ReactiveX/RxGo/subscription"

Index

Package Files

subscription.go

Variables

var DefaultSubscription = Subscription{}

DefaultSubscription is a default Subscription.

type Subscription Uses

type Subscription struct {
    SubscribeAt   time.Time
    UnsubscribeAt time.Time
    Error         error
}

Subscription is usually returned from any subscription

func New Uses

func New() Subscription

New creates a DefaultSubscription.

func (Subscription) Err Uses

func (s Subscription) Err() error

Err returns an error recorded from a stream.

func (Subscription) Subscribe Uses

func (s Subscription) Subscribe() Subscription

Subscribe records the time of subscription.

func (Subscription) Unsubscribe Uses

func (s Subscription) Unsubscribe() Subscription

Unsubscribe records the time of unsubscription.

Package subscription imports 1 packages (graph). Updated 2018-11-05. Refresh now. Tools for package owners.