subscribers

package
v0.5.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 20, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBlockFirstSubscriber added in v0.3.0 

func NewBlockFirstSubscriber(done chan struct{}, vchan chan<- reactor.Any, echan chan<- error) reactor.Subscriber

func ReturnBlockLastSubscriber added in v0.3.7 

func ReturnBlockLastSubscriber(s *BlockLastSubscriber)

func ReturnBlockSubscriber added in v0.4.6 

func ReturnBlockSubscriber(s *BlockSubscriber)

Types

type BlockLastSubscriber added in v0.3.7 

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

func BorrowBlockLastSubscriber added in v0.3.7 

func BorrowBlockLastSubscriber() *BlockLastSubscriber

func (*BlockLastSubscriber) Block added in v0.3.7 

func (b *BlockLastSubscriber) Block() (value reactor.Any, err error)

func (*BlockLastSubscriber) OnComplete added in v0.3.7 

func (b *BlockLastSubscriber) OnComplete()

func (*BlockLastSubscriber) OnError added in v0.3.7 

func (b *BlockLastSubscriber) OnError(err error)

func (*BlockLastSubscriber) OnNext added in v0.3.7 

func (b *BlockLastSubscriber) OnNext(value reactor.Any)

func (*BlockLastSubscriber) OnSubscribe added in v0.3.7 

func (b *BlockLastSubscriber) OnSubscribe(ctx context.Context, subscription reactor.Subscription)

type BlockSubscriber added in v0.4.6 

type BlockSubscriber struct {
	reactor.Item
	// contains filtered or unexported fields
}

func BorrowBlockSubscriber added in v0.4.6 

func BorrowBlockSubscriber() *BlockSubscriber

func (*BlockSubscriber) Done added in v0.4.6 

func (b *BlockSubscriber) Done() <-chan struct{}

func (*BlockSubscriber) OnComplete added in v0.4.6 

func (b *BlockSubscriber) OnComplete()

func (*BlockSubscriber) OnError added in v0.4.6 

func (b *BlockSubscriber) OnError(err error)

func (*BlockSubscriber) OnNext added in v0.4.6 

func (b *BlockSubscriber) OnNext(any reactor.Any)

func (*BlockSubscriber) OnSubscribe added in v0.4.6 

func (b *BlockSubscriber) OnSubscribe(ctx context.Context, subscription reactor.Subscription)

func (*BlockSubscriber) Reset added in v0.4.6 

func (b *BlockSubscriber) Reset()

type DoFinallySubscriber added in v0.0.5 

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

func NewDoFinallySubscriber added in v0.0.5 

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

func (*DoFinallySubscriber) Cancel added in v0.0.5 

func (d *DoFinallySubscriber) Cancel()

func (*DoFinallySubscriber) Dispose added in v0.4.2 

func (d *DoFinallySubscriber) Dispose()

func (*DoFinallySubscriber) OnComplete added in v0.0.5 

func (d *DoFinallySubscriber) OnComplete()

func (*DoFinallySubscriber) OnError added in v0.0.5 

func (d *DoFinallySubscriber) OnError(err error)

func (*DoFinallySubscriber) OnNext added in v0.0.5 

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

func (*DoFinallySubscriber) OnSubscribe added in v0.0.5 

func (d *DoFinallySubscriber) OnSubscribe(ctx context.Context, s reactor.Subscription)

func (*DoFinallySubscriber) Request added in v0.0.5 

func (d *DoFinallySubscriber) Request(n int)

type FnSwitchIfError added in v0.3.6 

type FnSwitchIfError = func(error) reactor.RawPublisher

type SwitchIfEmptySubscriber 

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

func NewSwitchIfEmptySubscriber 

func NewSwitchIfEmptySubscriber(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(ctx context.Context, su reactor.Subscription)

func (*SwitchIfEmptySubscriber) Request 

func (s *SwitchIfEmptySubscriber) Request(n int)

type SwitchIfErrorSubscriber added in v0.3.6 

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

func NewSwitchIfErrorSubscriber added in v0.3.6 

func NewSwitchIfErrorSubscriber(alternative FnSwitchIfError, actual reactor.Subscriber) *SwitchIfErrorSubscriber

func (*SwitchIfErrorSubscriber) Cancel added in v0.3.6 

func (s *SwitchIfErrorSubscriber) Cancel()

func (*SwitchIfErrorSubscriber) OnComplete added in v0.3.6 

func (s *SwitchIfErrorSubscriber) OnComplete()

func (*SwitchIfErrorSubscriber) OnError added in v0.3.6 

func (s *SwitchIfErrorSubscriber) OnError(err error)

func (*SwitchIfErrorSubscriber) OnNext added in v0.3.6 

func (s *SwitchIfErrorSubscriber) OnNext(any reactor.Any)

func (*SwitchIfErrorSubscriber) OnSubscribe added in v0.3.6 

func (s *SwitchIfErrorSubscriber) OnSubscribe(ctx context.Context, subscription reactor.Subscription)

func (*SwitchIfErrorSubscriber) Request added in v0.3.6 

func (s *SwitchIfErrorSubscriber) Request(n int)

type SwitchValueIfErrorSubscriber added in v0.3.7 

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

func NewSwitchValueIfErrorSubscriber added in v0.3.7 

func NewSwitchValueIfErrorSubscriber(actual reactor.Subscriber, value reactor.Any) *SwitchValueIfErrorSubscriber

func (*SwitchValueIfErrorSubscriber) Cancel added in v0.3.7 

func (s *SwitchValueIfErrorSubscriber) Cancel()

func (*SwitchValueIfErrorSubscriber) OnComplete added in v0.3.7 

func (s *SwitchValueIfErrorSubscriber) OnComplete()

func (*SwitchValueIfErrorSubscriber) OnError added in v0.3.7 

func (s *SwitchValueIfErrorSubscriber) OnError(err error)

func (*SwitchValueIfErrorSubscriber) OnNext added in v0.3.7 

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

func (*SwitchValueIfErrorSubscriber) OnSubscribe added in v0.3.7 

func (s *SwitchValueIfErrorSubscriber) OnSubscribe(ctx context.Context, su reactor.Subscription)

func (*SwitchValueIfErrorSubscriber) Request added in v0.3.7 

func (s *SwitchValueIfErrorSubscriber) Request(n int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.