| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observer.hpp | 71 template<class State, class OnError>
75 using onerror_t = rxu::decay_t<OnError>;
178 template<class T, class State, class OnNext, class OnError, class OnCompleted>
182 using this_type = observer<T, State, OnNext, OnError, OnCompleted>;
189 !std::is_same<void, OnError>::value,
190 rxu::decay_t<OnError>,
191 detail::OnErrorForward<State, OnError>>::type;
269 template<class T, class OnNext, class OnError, class OnCompleted>
270 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted> : public observer_b…
273 using this_type = observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>;
[all …]
|
| D | rx-subscriber.hpp | 274 template<class T, class OnNext, class OnError>
275 auto make_subscriber(const OnNext& on, const OnError& oe) in make_subscriber()
278 detail::is_on_error<OnError>::value, in make_subscriber()
279 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
280 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(trace_id::ma… in make_subscriber()
281 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
292 template<class T, class OnNext, class OnError, class OnCompleted>
293 auto make_subscriber(const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
296 detail::is_on_error<OnError>::value && in make_subscriber()
298 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
[all …]
|
| D | rx-predef.hpp | 77 template<class T, class State = void, class OnNext = void, class OnError = void, class OnCompleted …
81 template<class T, class OnNext, class OnError, class OnCompleted>
82 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>;
|
| /external/libchrome/mojo/core/ |
| D | channel_win.cc | 147 OnError(Error::kConnectionFailed); in StartOnIOThread()
161 OnError(Error::kConnectionFailed); in StartOnIOThread()
216 OnError(Error::kDisconnected); in OnIOCompleted()
246 OnError(Error::kReceivedMalformedData); in OnReadDone()
249 OnError(Error::kDisconnected); in OnReadDone()
297 OnError(Error::kDisconnected); in ReadMore()
334 OnError(error); in OnWriteError()
|
| D | channel_fuchsia.cc | 372 OnError(Error::kReceivedMalformedData); in OnZxHandleSignalled()
374 OnError(Error::kDisconnected); in OnZxHandleSignalled()
434 OnError(error); in OnWriteError()
|
| D | channel_posix.cc | 433 OnError(Error::kConnectionFailed); in OnFileCanReadWithoutBlocking()
480 OnError(Error::kReceivedMalformedData); in OnFileCanReadWithoutBlocking()
482 OnError(Error::kDisconnected); in OnFileCanReadWithoutBlocking()
698 OnError(error); in OnWriteError()
|
| D | channel.h | 321 void OnError(Error error);
|
| D | channel.cc | 725 void Channel::OnError(Error error) { in OnError() function in mojo::core::Channel
|
| /external/libbrillo/brillo/streams/ |
| D | stream_utils_unittest.cc | 176 void OnError(const std::string& expected_error, in OnError() function in brillo::CopyStreamDataTest
206 base::Bind(&CopyStreamDataTest::OnError, base::Unretained(this), "")); in TEST_F()
226 base::Bind(&CopyStreamDataTest::OnError, base::Unretained(this), "")); in TEST_F()
244 base::Bind(&CopyStreamDataTest::OnError, base::Unretained(this), "")); in TEST_F()
264 base::Bind(&CopyStreamDataTest::OnError, base::Unretained(this), "")); in TEST_F()
278 base::Bind(&CopyStreamDataTest::OnError, base::Unretained(this), "read")); in TEST_F()
294 base::Bind(&CopyStreamDataTest::OnError, base::Unretained(this), in TEST_F()
|
| /external/grpc-grpc/tools/codegen/core/ |
| D | gen_settings_ids.py | 24 OnError = collections.namedtuple('OnError', 'behavior code') variable
25 clamp_invalid_value = OnError('CLAMP_INVALID_VALUE', 'PROTOCOL_ERROR')
26 disconnect_on_invalid_value = lambda e: OnError('DISCONNECT_ON_INVALID_VALUE', e)
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | pubsubtasks_unittest.cc | 63 void OnError(buzz::IqTask* task, const buzz::XmlElement* stanza) { in OnError() function in TestPubSubTasksListener
148 listener.get(), &TestPubSubTasksListener::OnError); in TEST_F()
235 listener.get(), &TestPubSubTasksListener::OnError); in TEST_F()
257 listener.get(), &TestPubSubTasksListener::OnError); in TEST_F()
|
| D | mucroomlookuptask_unittest.cc | 31 void OnError(buzz::IqTask* task, in OnError() function in MucRoomLookupListener
158 task->SignalError.connect(listener, &MucRoomLookupListener::OnError); in TEST_F()
174 task->SignalError.connect(listener, &MucRoomLookupListener::OnError); in TEST_F()
|
| D | mucroomconfigtask_unittest.cc | 30 void OnError(buzz::IqTask* task, in OnError() function in MucRoomConfigListener
115 task->SignalError.connect(listener, &MucRoomConfigListener::OnError); in TEST_F()
|
| D | mucroomdiscoverytask_unittest.cc | 39 void OnError(buzz::IqTask* task, in OnError() function in MucRoomDiscoveryListener
132 task->SignalError.connect(listener, &MucRoomDiscoveryListener::OnError); in TEST_F()
|
| D | mucroomuniquehangoutidtask_unittest.cc | 31 void OnError(buzz::IqTask* task, in OnError() function in MucRoomUniqueHangoutIdListener
|
| /external/v8/src/wasm/ |
| D | streaming-decoder.h | 49 virtual void OnError(DecodeResult result) = 0;
205 if (ok_) processor_->OnError(std::move(result)); in Error()
|
| D | module-compiler.cc | 88 void OnError(ErrorThrower* thrower);
809 compilation_state_->OnError(&thrower); in RunInternal()
2180 void OnError(DecodeResult result) override;
2766 void AsyncStreamingProcessor::OnError(DecodeResult result) { in OnError() function in v8::internal::wasm::AsyncStreamingProcessor
2885 void CompilationState::OnError(ErrorThrower* thrower) { in OnError() function in v8::internal::wasm::CompilationState
|
| /external/webrtc/talk/media/base/ |
| D | testutils.h | 177 void OnError(uint32_t ssrc, VideoMediaChannel::Error error) { in OnError() function
|
| /external/caliper/caliper/src/test/resources/com/google/caliper/bridge/ |
| D | jdk7-flags.txt | 441 ccstrlist OnError = {product}
|
| D | jdk6-flags.txt | 410 ccstrlist OnError = {product}
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | README.md | 427 base::BindOnce(&LoggerImpl::OnError, base::Unretained(this)));
430 void LoggerImpl::OnError() {
|
| /external/python/cpython3/Tools/msi/bundle/bootstrap/ |
| D | PythonBootstrapperApplication.cpp | 1002 virtual STDMETHODIMP_(int) OnError( in OnError() function in PythonBootstrapperApplication
|