ReactiveStream

Inherits: Class, ReactiveSubject

Methods

GetNumPublishers

function ReactiveStream:GetNumPublishers()
  -> number

Gets the number of publishers on the stream.

Returns:

Type	Description
number

Publisher

function ReactiveStream:Publisher()
  -> ReactivePublisherSchema

Creates a new publisher for the stream.

Returns:

Type	Description
ReactivePublisherSchema

Release

function ReactiveStream:Release()

Releases the stream.

Send

function ReactiveStream:Send(data)

Sends a new data value the stream's publishers.

Parameters:

Name	Type	Description
data	T	The data to send

SetNoPublishersCallback

function ReactiveStream:SetNoPublishersCallback(handler)
  -> self

Sets a callback for when there are no remaining publishers.

Parameters:

Name	Type	Description
handler	fun(stream: ReactiveStream)	The handler function

Returns:

Type	Description
self

_Acquire

function ReactiveStream:_Acquire(initialValueFunc)

Parameters:

Name	Type	Description
initialValueFunc	fun(): T

__init

function ReactiveStream:__init()

Functions

Get

function ReactiveStream.Get(initialValueFunc)
  -> ReactiveStream

Gets a stream object.

Parameters:

Name	Type	Description
initialValueFunc	fun(): T	A function to get the initial value to send to new publishers

Returns:

Type	Description
ReactiveStream

_initialValueFunc

function ReactiveStream._initialValueFunc()
  -> <T>

Returns:

Type	Description
<T>