| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/event_handler/subscribe_errors/ |
| H A D | main.cpp | 84 so_subscribe( m_mbox ) in so_define_agent()
93 so_subscribe( m_mbox ).event( &test_agent_t::evt_handler1 ); in so_evt_start()
94 so_subscribe( m_mbox ).in( m_state_a ).event( in so_evt_start()
96 so_subscribe( m_mbox ).in( m_state_b ).event( in so_evt_start()
99 ENSURE_EXCEPTION( so_subscribe( m_mbox ).event( in so_evt_start()
101 ENSURE_EXCEPTION( so_subscribe( m_mbox ).event( in so_evt_start()
104 ENSURE_EXCEPTION( so_subscribe( m_mbox ).in( m_state_a ).event( in so_evt_start()
106 ENSURE_EXCEPTION( so_subscribe( m_mbox ).in( m_state_a ).event( in so_evt_start()
109 ENSURE_EXCEPTION( so_subscribe( m_mbox ).in( m_state_b ).event( in so_evt_start()
111 ENSURE_EXCEPTION( so_subscribe( m_mbox ).in( m_state_b ).event( in so_evt_start()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/drop_subscr_when_demand_in_queue/ |
| H A D | main.cpp | 33 so_subscribe( m_mbox ) in so_define_agent()
35 so_subscribe( m_mbox ) in so_define_agent()
37 so_subscribe( m_mbox ) in so_define_agent()
39 so_subscribe( m_mbox ) in so_define_agent()
58 so_subscribe( m_mbox ).event( &a_test_t::evt_two ); in evt_one()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mutable_msg/subscr_to_mutable_from_mpmc_mbox/ |
| H A D | main.cpp | 53 so_subscribe(m_mbox).event( []( mutable_mhood_t<first> ) {} ); in so_evt_start()
59 so_subscribe(m_mbox).event( &sobj_message_tester::on_first ); in so_evt_start()
88 so_subscribe(m_mbox).event( []( mutable_mhood_t<first> ) {} ); in so_evt_start()
94 so_subscribe(m_mbox).event( &user_message_tester::on_first ); in so_evt_start()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/mpsc_mbox/ |
| H A D | main.cpp | 31 so_subscribe( so_direct_mbox() ) in so_define_agent()
33 so_subscribe( so_direct_mbox() ) in so_define_agent()
35 so_subscribe( so_direct_mbox() ) in so_define_agent()
66 so_subscribe( so_direct_mbox() ).event( &a_test_t::evt_two ); in evt_three()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/subscribe_when_deregistered/ |
| H A D | main.cpp | 67 so_subscribe( m_mbox ) in so_evt_finish()
69 so_subscribe( m_mbox ) in so_evt_finish()
71 so_subscribe( m_mbox ) in so_evt_finish()
73 so_subscribe( m_mbox ) in so_evt_finish()
75 so_subscribe( m_mbox ) in so_evt_finish()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/state/change_state/ |
| H A D | main.cpp | 76 so_subscribe( m_test_mbox ) in so_define_agent()
81 so_subscribe( m_test_mbox ) in so_define_agent()
87 so_subscribe( m_test_mbox ) in so_define_agent()
93 so_subscribe( m_test_mbox ) in so_define_agent()
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/mboxes/retained_msg/delivery_filter/ |
| H A D | main.cpp | 51 so_subscribe(m_control_mbox).event( in so_define_agent()
53 so_subscribe(m_retained_mbox).event( in so_define_agent()
84 so_subscribe(m_control_mbox).event( in so_define_agent()
86 so_subscribe(m_retained_mbox).event( in so_define_agent()
117 so_subscribe(m_control_mbox).event( in so_define_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/hanging_subscriptions/ |
| H A D | main.cpp | 116 so_subscribe( mbox ).event( &a_first_t::evt_one ); in a_first_t()
117 so_subscribe( mbox ).event( &a_first_t::evt_two ); in a_first_t()
137 so_subscribe( mbox ).event( &a_second_t::evt_one ); in a_second_t()
153 so_subscribe( mbox ).event( &a_third_t::evt_two ); in a_third_t()
154 so_subscribe( mbox ).event( &a_third_t::evt_one ); in a_third_t()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/doxygen/dox/so_5/ |
| H A D | so_5_4_0__event_method_chaining.dox | 3 \page so_5_4_0__event_method_chaining so-5.4.0: so_subscribe().event() methods chaining
14 so_subscribe( so_direct_mbox() ).in( st_disconnected )
27 the chain so_subscribe(mbox).in(s1).in(s2).event(e1).in(s3).event(e2) event e1
30 so_subscribe(mbox).event(e3).in(s4) has no sence: event e3 will be subscribed
|
| H A D | so_5_3_0__new_event_handlers_formats.dox | 36 so_subscribe(mbox).event( &my_agent_t::evt_convert );
49 But is must be subscribed by new version of so_subscribe().event() chain:
54 so_subscribe(mbox).event(
78 so_subscribe(mbox).event(
81 so_subscribe(mbox).event(
|
| H A D | so_5_5_1__subscribe_event_via_state.dox | 6 `so_subscribe().in().event()` chain. But sometimes this way is too verbose.
25 so_subscribe( m_configurator_mbox ).in( st_not_connected )
27 so_subscribe( m_configurator_mbox ).in( st_connected )
|
| H A D | so_5_5_19_has_subscription.md | 13 so_subscribe(cmd->from_).event(&observer::on_data);
19 …ox to which the observer is already subscribed the an exception will be throw in in `so_subscribe`.
29 so_subscribe(cmd->from_).event(&observer::on_data);
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/timer_thread/single_timer_zero_delay/ |
| H A D | main.cpp | 37 so_subscribe( m_mbox ) in so_define_agent()
40 so_subscribe( m_mbox ) in so_define_agent()
43 so_subscribe( m_mbox ) in so_define_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/messages/store_and_resend_later/ |
| H A D | main.cpp | 181 so_subscribe( m_mbox ) in so_define_agent()
184 so_subscribe( m_mbox ).in( st_stored ) in so_define_agent()
187 so_subscribe( m_mbox ).in( st_stored ) in so_define_agent()
190 so_subscribe( m_mbox ).in( st_stored ) in so_define_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/msg_tracing/change_filter_1/ |
| H A D | main.cpp | 27 so_subscribe( m_mbox1 ).event( &a_test_t::first_event ); in so_evt_start()
49 so_subscribe( m_mbox2 ).event( &a_test_t::second_event ); in first_event()
61 so_subscribe( m_mbox3 ).event( &a_test_t::third_event ); in second_event()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/sample/so_5/adv_thread_pool_fifo/ |
| H A D | main.cpp | 32 so_subscribe( so_environment().create_mbox( "log" ) ) in create_logger()
65 so_subscribe( so_environment().create_mbox( "demo" ) )
86 so_subscribe( so_environment().create_mbox( "demo" ) )
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/mbox/mpsc_mbox_illegal_subscriber/ |
| H A D | main.cpp | 25 so_subscribe( so_direct_mbox() ).event( &a_first_t::evt_one ); in so_define_agent()
55 so_subscribe( m_mbox ).event( &a_second_t::evt_one ); in so_define_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/messages/user_type_msgs/event_data/ |
| H A D | main.cpp | 21 so_subscribe( m_m1 ).event( &a_test_t::evt_one ); in so_define_agent()
22 so_subscribe( m_m2 ).event( &a_test_t::evt_two ); in so_define_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/sample/so_5/ping_pong_minimal/ |
| H A D | main.cpp | 21 so_subscribe( m_mbox ).event( &a_pinger_t::evt_pong ); in so_define_agent()
55 so_subscribe( mbox ).event( in a_ponger_t()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/msg_tracing/simple_msg_count/ |
| H A D | main.cpp | 32 so_subscribe( m_data_mbox ).event( &a_test_t::evt_finish ); in so_define_agent()
33 so_subscribe( m_data_mbox ).event( &a_test_t::evt_dummy_msg ); in so_define_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/disp/prio_ot_quoted_round_robin/simple_quote/ |
| H A D | main.cpp | 42 so_subscribe( m_common_mbox ).event( in define_receiver_agent()
70 so_subscribe( common_mbox ).event( in define_message_sender()
110 so_subscribe( m_common_mbox ) in define_supervison_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/timer_thread/single_periodic/ |
| H A D | main.cpp | 78 so_subscribe( m_test_mbox ) in so_define_agent()
81 so_subscribe( m_test_mbox ) in so_define_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/sample/so_5/delivery_filters/ |
| H A D | main.cpp | 48 so_subscribe( m_mbox ).event( []( const msg_sample & evt ) { in so_evt_start()
79 so_subscribe( m_mbox ).event( []( const msg_sample & evt ) { in evt_second_part()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/disp/adv_thread_pool/chstate_in_safe/ |
| H A D | main.cpp | 44 so_subscribe( so_direct_mbox() ).in( st_unsafe ) in so_define_agent()
47 so_subscribe( so_direct_mbox() ).in( st_safe ) in so_define_agent()
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/msg_tracing/simple_deny_msg_filter/ |
| H A D | main.cpp | 45 so_subscribe( m_data_mbox ).event( &a_test_t::evt_finish ); in so_define_agent()
46 so_subscribe( m_data_mbox ).event( &a_test_t::evt_dummy_msg ); in so_define_agent()
|