Skip to main content

API

ReactiveProducer​

Declaration
class ReactiveProducer {
  void payload(dynamic data, {bool complete = false})
  void error(String message)
  void cancel() 
  void complete()
  void request(int count)
  void unbound()
}

Methods​

payload​

Produces new payload data to a channel.

error​

Produces new error data to a channel.

cancel​

Cancels a channel.

complete​

Completes a channel.

request​

Requests new data from a channel.

unbound​

Requests infinity (2147483647) data from a channel.