rxdart_ext 0.1.1-dev.0

Some extension methods and classes built on top of RxDart - RxDart extension.

rxdart_ext

Author: Petrus Nguyễn Thái Học

Some extension methods and classes built on top of RxDart - RxDart extension.

API

Single

A Stream which emits single event, either data or error, and then close with a done-event.

Success case: ------(*)-------------------------|---
                   data                        done

Failure case: ------(x)-------------------------|---
                   error                       done

• Create Single

  • Factories and static methods.

    • Single.value
    • Single.error
    • Single.fromFuture
    • Single.fromCallable
    • Single.timer
    • Single.defer
    • Single.zip2

  • Convert others to Single via extensions.

    • Stream.singleOrError
    • Future.asSingle
    • (FutureOr

• Operators for Single

  • flatMapSingle
  • asyncExpandSingle
  • switchMapSingle
  • exhaustMapSingle
  • delay

Operators for Stream

• debug, collect
• ForwardingSinkMixin
• distinctUniqueBy
• distinctBy
• ignoreElements, ignoreErrors
• mapNotNull
• toSingleSubscription
• asVoid
• whereNotNull

NotReplayValueStream

A Stream that provides synchronous access to the last emitted item, but not replay the latest value.

• NotReplayValueStream
  • Broadcast
    • ValueSubject
    • NotReplayValueConnectableStream, publishValueNotReplay, shareValueNotReplay
  • Single-subscription
    • ValueStreamController
    • toNotReplayValueStream

RxDart compatibility

rxdart	rxdart_ext
^0.26.0	^0.0.1
^0.27.0	^0.1.0