44 struct OnNextForward  struct
46     using state_t = rxu::decay_t<State>;
47     using onnext_t = rxu::decay_t<OnNext>;
48     OnNextForward() : onnext() {}  in OnNextForward()  function
49     explicit OnNextForward(onnext_t on) : onnext(std::move(on)) {}  in OnNextForward()  function
50     onnext_t onnext;
51     void operator()(state_t& s, T& t) const {  in operator ()()
54     void operator()(state_t& s, T&& t) const {  in operator ()()
59 struct OnNextForward<T, State, void>  struct
61     using state_t = rxu::decay_t<State>;
62     OnNextForward() {}  in OnNextForward()  argument
63     void operator()(state_t& s, T& t) const {  in operator ()()
66     void operator()(state_t& s, T&& t) const {  in operator ()()