subscribers

Documentation

Index

• type DoFinallySubscriber
  • func NewDoFinallySubscriber(actual reactor.Subscriber, onFinally reactor.FnOnFinally) *DoFinallySubscriber
  • func (p *DoFinallySubscriber) Cancel()
  • func (p *DoFinallySubscriber) OnComplete()
  • func (p *DoFinallySubscriber) OnError(err error)
  • func (p *DoFinallySubscriber) OnNext(v reactor.Any)
  • func (p *DoFinallySubscriber) OnSubscribe(s reactor.Subscription)
  • func (p *DoFinallySubscriber) Request(n int)
• type SwitchIfEmptySubscriber
  • func NewSwitchIfEmptySubscriber(ctx context.Context, alternative reactor.RawPublisher, ...) *SwitchIfEmptySubscriber
  • func (s *SwitchIfEmptySubscriber) Cancel()
  • func (s *SwitchIfEmptySubscriber) OnComplete()
  • func (s *SwitchIfEmptySubscriber) OnError(err error)
  • func (s *SwitchIfEmptySubscriber) OnNext(v reactor.Any)
  • func (s *SwitchIfEmptySubscriber) OnSubscribe(su reactor.Subscription)
  • func (s *SwitchIfEmptySubscriber) Request(n int)

Types

type DoFinallySubscriber

type DoFinallySubscriber struct {
	// contains filtered or unexported fields
}

func NewDoFinallySubscriber

func NewDoFinallySubscriber(actual reactor.Subscriber, onFinally reactor.FnOnFinally) *DoFinallySubscriber

func (*DoFinallySubscriber) Cancel

func (p *DoFinallySubscriber) Cancel()

func (*DoFinallySubscriber) OnComplete

func (p *DoFinallySubscriber) OnComplete()

func (*DoFinallySubscriber) OnError

func (p *DoFinallySubscriber) OnError(err error)

func (*DoFinallySubscriber) OnNext

func (p *DoFinallySubscriber) OnNext(v reactor.Any)

func (*DoFinallySubscriber) OnSubscribe

func (p *DoFinallySubscriber) OnSubscribe(s reactor.Subscription)

func (*DoFinallySubscriber) Request

func (p *DoFinallySubscriber) Request(n int)

type SwitchIfEmptySubscriber

type SwitchIfEmptySubscriber struct {
	// contains filtered or unexported fields
}

func NewSwitchIfEmptySubscriber

func NewSwitchIfEmptySubscriber(ctx context.Context, alternative reactor.RawPublisher, actual reactor.Subscriber) *SwitchIfEmptySubscriber

func (*SwitchIfEmptySubscriber) Cancel

func (s *SwitchIfEmptySubscriber) Cancel()

func (*SwitchIfEmptySubscriber) OnComplete

func (s *SwitchIfEmptySubscriber) OnComplete()

func (*SwitchIfEmptySubscriber) OnError

func (s *SwitchIfEmptySubscriber) OnError(err error)

func (*SwitchIfEmptySubscriber) OnNext

func (s *SwitchIfEmptySubscriber) OnNext(v reactor.Any)

func (*SwitchIfEmptySubscriber) OnSubscribe

func (s *SwitchIfEmptySubscriber) OnSubscribe(su reactor.Subscription)

func (*SwitchIfEmptySubscriber) Request

func (s *SwitchIfEmptySubscriber) Request(n int)