IsWrongTupleTypeError returns true if target error is type of wrong tuple type.

NewSubscriber create a new Subscriber with custom options.

NewTuple returns a new Tuple.

OnComplete returns s SubscriberOption handling Complete event.

OnError returns s SubscriberOption handling Error event.

OnNext returns s SubscriberOption handling Next event.

OnSubscribe returns s SubscriberOption handling Subscribe event.

RequestMax represents unbounded request amount.

SignalCancel indicates that subscriber was cancelled.

SignalComplete indicated that subscriber was completed.

SignalError indicates that subscriber has some faults.

EmptyRawSubscriber is a blank native Subscriber in reactor-go.

EmptySubscriber is a blank Subscriber.

Item is a kind of container which contains value or error.

Publisher is a provider of a potentially unbounded number of sequenced elements, \ publishing them according to the demand received from its Subscriber(s).

RawPublisher represents a basic Publisher which can be subscribed by a Subscriber.

Subscriber will receive call to OnSubscribe(Subscription) once after passing an instance of Subscriber to Publisher#SubscribeWith.

SignalType is the signal of reactive events like `OnNext`, `OnComplete`, `OnCancel` and `OnError`.

SubscriberOption is option of subscriber.

Subscription represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher.

Tuple is a container contains multiple items.