progress

package

v0.0.30 Latest Latest Go to latest Published: Nov 15, 2024 License: GPL-3.0 Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/unstoppablemango/tdl

Links

Open Source Insights

Documentation ¶

Index ¶

func Subscribe(o Observable, report ReportFunc) rx.Subscription
type Event
type Observable
type Reader
- func NewReader(r io.Reader, total int) Reader
type ReportFunc
type Writer
- func NewWriter(w io.Writer, total int) Writer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Subscribe(o Observable, report ReportFunc) rx.Subscription

Types ¶

type Event ¶

type Event struct {
	Percent float64
}

type Observable ¶

type Observable interface {
	rx.Observable[Event]
}

type Reader ¶

type Reader interface {
	Observable
	io.Reader
}

func NewReader ¶

func NewReader(r io.Reader, total int) Reader

type ReportFunc ¶

type ReportFunc func(float64, error)

func (ReportFunc) OnComplete ¶

func (r ReportFunc) OnComplete()

OnComplete implements rx.Observer.

func (ReportFunc) OnError ¶

func (r ReportFunc) OnError(err error)

OnError implements rx.Observer.

func (ReportFunc) OnNext ¶

func (r ReportFunc) OnNext(e Event)

OnNext implements rx.Observer.

type Writer ¶

type Writer interface {
	Observable
	io.Writer
}

func NewWriter ¶

func NewWriter(w io.Writer, total int) Writer

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL