| /dports/devel/py-rx/Rx-3.2.0/rx/core/operators/ |
| H A D | merge.py | 61 def on_next(inner_source): argument
64 subscribe(inner_source)
66 queue.append(inner_source)
99 def on_next(inner_source): argument
103 … inner_source = from_future(inner_source) if is_future(inner_source) else inner_source
113 subscription = inner_source.subscribe_(on_next, on_error, on_completed, scheduler)
|
| H A D | exclusive.py | 28 def on_next(inner_source): argument
32 … inner_source = rx.from_future(inner_source) if is_future(inner_source) else inner_source
43 inner_subscription.disposable = inner_source.subscribe_(
|
| H A D | switchlatest.py | 30 def on_next(inner_source: Union[Observable, Future]):
41 if is_future(inner_source):
42 obs = from_future(cast(Future, inner_source))
44 obs = cast(Observable, inner_source)
|
| /dports/devel/py-rx1/Rx-1.6.1/rx/linq/observable/ |
| H A D | merge.py | 56 def on_next(inner_source): argument
59 subscribe(inner_source)
61 q.append(inner_source)
121 def on_next(inner_source): argument
125 inner_source = Observable.from_future(inner_source)
135 disposable = inner_source.subscribe(on_next, observer.on_error, on_completed)
|
| H A D | exclusive.py | 27 def on_next(inner_source): argument
31 inner_source = Observable.from_future(inner_source)
42 inner_subscription.disposable = inner_source.subscribe(
|
| H A D | switchlatest.py | 27 def on_next(inner_source): argument
36 inner_source = Observable.from_future(inner_source)
52 d.disposable = inner_source.subscribe(on_next, on_error, on_completed)
|
| /dports/devel/glib20/glib-2.70.4/gio/ |
| H A D | gunixinputstream.c | 469 GSource *inner_source, *cancellable_source, *pollable_source; in g_unix_input_stream_pollable_create_source() local
473 inner_source = g_unix_fd_source_new (unix_stream->priv->fd, G_IO_IN); in g_unix_input_stream_pollable_create_source()
474 g_source_set_dummy_callback (inner_source); in g_unix_input_stream_pollable_create_source()
475 g_source_add_child_source (pollable_source, inner_source); in g_unix_input_stream_pollable_create_source()
476 g_source_unref (inner_source); in g_unix_input_stream_pollable_create_source()
|
| H A D | gunixoutputstream.c | 556 GSource *inner_source, *cancellable_source, *pollable_source; in g_unix_output_stream_pollable_create_source() local
560 inner_source = g_unix_fd_source_new (unix_stream->priv->fd, G_IO_OUT); in g_unix_output_stream_pollable_create_source()
561 g_source_set_dummy_callback (inner_source); in g_unix_output_stream_pollable_create_source()
562 g_source_add_child_source (pollable_source, inner_source); in g_unix_output_stream_pollable_create_source()
563 g_source_unref (inner_source); in g_unix_output_stream_pollable_create_source()
|
| /dports/lang/rust/rustc-1.58.1-src/compiler/rustc_monomorphize/src/ |
| H A D | collector.rs | 1023 let ptr_vtable = |inner_source: Ty<'tcx>, inner_target: Ty<'tcx>| { in find_vtable_types_for_unsizing()
1036 if type_has_metadata(inner_source) { in find_vtable_types_for_unsizing()
1037 (inner_source, inner_target) in find_vtable_types_for_unsizing()
1039 tcx.struct_lockstep_tails_erasing_lifetimes(inner_source, inner_target, param_env) in find_vtable_types_for_unsizing()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/examples/destinations/example_destination/ |
| H A D | example_destination-grammar.y | 831 inner_source
858 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/afuser/ |
| H A D | afuser-grammar.y | 839 inner_source
866 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/examples/inner-destinations/http-test-slots/ |
| H A D | http-test-slots-grammar.y | 841 inner_source
868 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/examples/sources/threaded-diskq-source/ |
| H A D | threaded-diskq-source-grammar.y | 849 inner_source
876 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/ |
| H A D | block-ref-grammar.y | 828 inner_source
855 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/map-value-pairs/ |
| H A D | map-value-pairs-grammar.y | 828 inner_source
855 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/tagsparser/ |
| H A D | tags-parser-grammar.y | 839 inner_source
866 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/openbsd/ |
| H A D | openbsd-grammar.y | 844 inner_source
871 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/parser/ |
| H A D | parser-expr-grammar.y | 843 inner_source
870 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/add-contextual-data/ |
| H A D | add-contextual-data-grammar.y | 881 inner_source
908 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/afprog/ |
| H A D | afprog-grammar.y | 879 inner_source
906 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/afsmtp/ |
| H A D | afsmtp-grammar.y | 926 inner_source
953 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/appmodel/ |
| H A D | appmodel-grammar.y | 864 inner_source
891 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/csvparser/ |
| H A D | csvparser-grammar.y | 903 inner_source
930 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/azure-auth-header/ |
| H A D | azure-auth-header-grammar.y | 858 inner_source
885 : inner_source
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/examples/sources/msg-generator/ |
| H A D | msg-generator-grammar.y | 882 inner_source
909 : inner_source
|