Same as rpp::subjects::behavior_subject but on_next/on_error/on_completed calls are serialized via mutex. More...

#include <behavior_subject.hpp>

Additional Inherited Members
Public Types inherited from rpp::subjects::details::behavior_subject_base< Type, true >
using	optimal_disposables_strategy

Public Member Functions inherited from rpp::subjects::details::behavior_subject_base< Type, true >
	behavior_subject_base (const Type &value)

	behavior_subject_base (Type &&value)

auto	get_observer () const

auto	get_observable () const

rpp::disposable_wrapper	get_disposable () const

Type	get_value () const

Detailed Description

template<rpp::constraint::decayed_type Type>
class rpp::subjects::serialized_behavior_subject< Type >

Same as rpp::subjects::behavior_subject but on_next/on_error/on_completed calls are serialized via mutex.

When you are using ordinary rpp::subjects::behavior_subject, then you must take care not to call its on_next method (or its other on methods) in async way.

See also: https://reactivex.io/documentation/subject.html

The documentation for this class was generated from the following files:

src/rpp/rpp/subjects/behavior_subject.hpp
src/rpp/rpp/subjects/fwd.hpp

Additional Inherited Members

Detailed Description