package
0.8.14
Repository: https://github.com/rsocket/rsocket-go.git
Documentation: pkg.go.dev

# Functions

Create wraps a generator function to a Mono.
CreateFromChannel creates a Mono from channels.
CreateOneshot wraps a generator function to an oneshot Mono.
No description provided by the author
Empty returns an empty Mono.
Error wraps an error to a Mono.
ErrorOneshot wraps an error to an oneshot Mono.
No description provided by the author
IsSubscribeAsync returns true if target Mono will be subscribed async.
Just wrap an exist Payload to a Mono.
JustOneshot wraps an existing Payload to an oneshot Mono.
JustOrEmpty wraps an existing Payload to a Mono.
No description provided by the author
Raw wrap a low-level Mono.
No description provided by the author
Zip merges given Monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple.
ZipAll merges given Monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple.

# Interfaces

Mono is a Reactive Streams Publisher with basic rx operators that completes successfully by emitting an element, or with an error.
Sink is a wrapper API around an actual downstream Subscriber for emitting nothing, a single value or an error (mutually exclusive).

# Type aliases

No description provided by the author
No description provided by the author
No description provided by the author
ReleaseFunc can be used to release resources.
ZipBuilder can be used to build a zipped Mono.