grpc_core::promise_detail::ObservableState< T > Class Template Reference

#include <observable.h>

Public Member Functions
void	Close ()
	ObservableState (absl::optional< T > value)
Poll< absl::optional< T > >	PollGet (ObservableVersion *version_seen)
Poll< absl::optional< T > >	PollNext (ObservableVersion *version_seen)
Poll< absl::optional< T > >	PollWatch (ObservableVersion *version_seen)
void	Push (T value)

Private Member Functions
WaitSet waiters_	ABSL_GUARDED_BY (mu_)
ObservableVersion version_	ABSL_GUARDED_BY (mu_)
absl::optional< T > value_	ABSL_GUARDED_BY (mu_)
bool	NextValueReady (ObservableVersion *version_seen) ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu_)
bool	Started () ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu_)

Private Attributes
Mutex	mu_

Detailed Description

template<typename T>
class grpc_core::promise_detail::ObservableState< T >

Definition at line 59 of file observable.h.

Constructor & Destructor Documentation

ObservableState()

template<typename T >

grpc_core::promise_detail::ObservableState< T >::ObservableState ( absl::optional< T >  value )

inlineexplicit

Definition at line 61 of file observable.h.

Member Function Documentation

ABSL_GUARDED_BY() [1/3]

template<typename T >

WaitSet waiters_ grpc_core::promise_detail::ObservableState< T >::ABSL_GUARDED_BY ( mu_  )

private

ABSL_GUARDED_BY() [2/3]

template<typename T >

ObservableVersion version_ grpc_core::promise_detail::ObservableState< T >::ABSL_GUARDED_BY ( mu_  )

private

ABSL_GUARDED_BY() [3/3]

template<typename T >

absl::optional<T> value_ grpc_core::promise_detail::ObservableState< T >::ABSL_GUARDED_BY ( mu_  )

private

Close()

template<typename T >

void grpc_core::promise_detail::ObservableState< T >::Close ( )

inline

Definition at line 65 of file observable.h.

NextValueReady()

template<typename T >

bool grpc_core::promise_detail::ObservableState< T >::NextValueReady ( ObservableVersion *  version_seen )

inlineprivate

Definition at line 124 of file observable.h.

PollGet()

template<typename T >

Poll<absl::optional<T> > grpc_core::promise_detail::ObservableState< T >::PollGet ( ObservableVersion *  version_seen )

inline

Definition at line 84 of file observable.h.

PollNext()

template<typename T >

Poll<absl::optional<T> > grpc_core::promise_detail::ObservableState< T >::PollNext ( ObservableVersion *  version_seen )

inline

Definition at line 91 of file observable.h.

PollWatch()

template<typename T >

Poll<absl::optional<T> > grpc_core::promise_detail::ObservableState< T >::PollWatch ( ObservableVersion *  version_seen )

inline

Definition at line 97 of file observable.h.

Push()

template<typename T >

void grpc_core::promise_detail::ObservableState< T >::Push ( T  value )

inline

Definition at line 75 of file observable.h.

Started()

template<typename T >

bool grpc_core::promise_detail::ObservableState< T >::Started ( )

inlineprivate

Definition at line 110 of file observable.h.

Member Data Documentation

mu_

template<typename T >

Mutex grpc_core::promise_detail::ObservableState< T >::mu_

private

Definition at line 135 of file observable.h.

---

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

• observable.h